Skip to content
Snippets Groups Projects

Compare revisions

Changes are shown as if the source revision was being merged into the target revision. Learn more about comparing revisions.

Source

Select target project
No results found
Select Git revision

Target

Select target project
  • danet/gosdn
1 result
Select Git revision
Show changes
Commits on Source (23)
Hide whitespace changes
Inline Side-by-side
Showing
with 199 additions and 158 deletions
.gitlab/ci/.renovate.yml
View file @ bbdaec53
renovate:
stage: tools
image: renovate/renovate:37.419.1
image: renovate/renovate:37.426.2
variables:
LOG_LEVEL: debug
......
.gitlab/ci/.test.yml
View file @ bbdaec53
......@@ -39,3 +39,13 @@ integration-test-gosdn:
script:
- go test -p 1 ./integration-tests/*
<<: *test
unit-test:
image: ${CI_DEPENDENCY_PROXY_GROUP_IMAGE_PREFIX}/golang:$GOLANG_VERSION-bookworm
before_script:
- apt update && apt install -y make
script:
- make unit-test-new
needs:
- []
<<: *test
Makefile
View file @ bbdaec53
......@@ -9,7 +9,7 @@ GOBIN := $(GOSDN_PRG)
SCRIPTS_DIR := /scripts
MAKEFILE_SUBDIR := ./makefiles
GOCMD=go
GOCMD=CGO_ENABLED=0 go
GOBUILD=$(GOCMD) build
GOCLEAN=$(GOCMD) clean -cache -fuzzcache -testcache -modcache
BUILD_ARTIFACTS_PATH=artifacts
......@@ -106,6 +106,9 @@ integration-tests-debug-up: generate-certs containerize-gosdn containerize-plugi
integration-tests-debug-down:
docker-compose -f dev_env_data/docker-compose/integration-test_docker-compose.yml down
unit-test-new: install-tools
go test ./cli/...
# Warning: Depending on your go and development configuration might also clean caches, modules and docker containers from your other projects.
clean:
rm -rf $(BUILD_ARTIFACTS_PATH)
......
api/go/github.com/openconfig/gnmi/proto/collector/collector.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: github.com/openconfig/gnmi/proto/collector/collector.proto
......@@ -154,7 +154,7 @@ func file_github_com_openconfig_gnmi_proto_collector_collector_proto_rawDescGZIP
}
var file_github_com_openconfig_gnmi_proto_collector_collector_proto_msgTypes = make([]protoimpl.MessageInfo, 2)
var file_github_com_openconfig_gnmi_proto_collector_collector_proto_goTypes = []interface{}{
var file_github_com_openconfig_gnmi_proto_collector_collector_proto_goTypes = []any{
(*ReconnectRequest)(nil), // 0: gnmi.ReconnectRequest
(*Nil)(nil), // 1: gnmi.Nil
}
......@@ -174,7 +174,7 @@ func file_github_com_openconfig_gnmi_proto_collector_collector_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_github_com_openconfig_gnmi_proto_collector_collector_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_collector_collector_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*ReconnectRequest); i {
case 0:
return &v.state
......@@ -186,7 +186,7 @@ func file_github_com_openconfig_gnmi_proto_collector_collector_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_collector_collector_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_collector_collector_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*Nil); i {
case 0:
return &v.state
......
api/go/github.com/openconfig/gnmi/proto/collector/collector_grpc.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: github.com/openconfig/gnmi/proto/collector/collector.proto
......@@ -31,8 +31,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
Collector_Reconnect_FullMethodName = "/gnmi.Collector/Reconnect"
......@@ -56,8 +56,9 @@ func NewCollectorClient(cc grpc.ClientConnInterface) CollectorClient {
}
func (c *collectorClient) Reconnect(ctx context.Context, in *ReconnectRequest, opts ...grpc.CallOption) (*Nil, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Nil)
err := c.cc.Invoke(ctx, Collector_Reconnect_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, Collector_Reconnect_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......
api/go/github.com/openconfig/gnmi/proto/gnmi/gnmi.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: github.com/openconfig/gnmi/proto/gnmi/gnmi.proto
......@@ -2737,7 +2737,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_rawDescGZIP() []byte
var file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_enumTypes = make([]protoimpl.EnumInfo, 5)
var file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes = make([]protoimpl.MessageInfo, 26)
var file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_goTypes = []interface{}{
var file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_goTypes = []any{
(Encoding)(0), // 0: gnmi.Encoding
(SubscriptionMode)(0), // 1: gnmi.SubscriptionMode
(SubscriptionList_Mode)(0), // 2: gnmi.SubscriptionList.Mode
......@@ -2852,7 +2852,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Notification); i {
case 0:
return &v.state
......@@ -2864,7 +2864,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*Update); i {
case 0:
return &v.state
......@@ -2876,7 +2876,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*TypedValue); i {
case 0:
return &v.state
......@@ -2888,7 +2888,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*Path); i {
case 0:
return &v.state
......@@ -2900,7 +2900,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*PathElem); i {
case 0:
return &v.state
......@@ -2912,7 +2912,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*Value); i {
case 0:
return &v.state
......@@ -2924,7 +2924,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*Error); i {
case 0:
return &v.state
......@@ -2936,7 +2936,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[7].Exporter = func(v any, i int) any {
switch v := v.(*Decimal64); i {
case 0:
return &v.state
......@@ -2948,7 +2948,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[8].Exporter = func(v any, i int) any {
switch v := v.(*ScalarArray); i {
case 0:
return &v.state
......@@ -2960,7 +2960,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[9].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeRequest); i {
case 0:
return &v.state
......@@ -2972,7 +2972,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[10].Exporter = func(v any, i int) any {
switch v := v.(*Poll); i {
case 0:
return &v.state
......@@ -2984,7 +2984,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[11].Exporter = func(v any, i int) any {
switch v := v.(*SubscribeResponse); i {
case 0:
return &v.state
......@@ -2996,7 +2996,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[12].Exporter = func(v any, i int) any {
switch v := v.(*SubscriptionList); i {
case 0:
return &v.state
......@@ -3008,7 +3008,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[13].Exporter = func(v any, i int) any {
switch v := v.(*Subscription); i {
case 0:
return &v.state
......@@ -3020,7 +3020,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[14].Exporter = func(v any, i int) any {
switch v := v.(*QOSMarking); i {
case 0:
return &v.state
......@@ -3032,7 +3032,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[15].Exporter = func(v any, i int) any {
switch v := v.(*Alias); i {
case 0:
return &v.state
......@@ -3044,7 +3044,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[16].Exporter = func(v any, i int) any {
switch v := v.(*AliasList); i {
case 0:
return &v.state
......@@ -3056,7 +3056,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[17].Exporter = func(v any, i int) any {
switch v := v.(*SetRequest); i {
case 0:
return &v.state
......@@ -3068,7 +3068,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[18].Exporter = func(v any, i int) any {
switch v := v.(*SetResponse); i {
case 0:
return &v.state
......@@ -3080,7 +3080,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[19].Exporter = func(v any, i int) any {
switch v := v.(*UpdateResult); i {
case 0:
return &v.state
......@@ -3092,7 +3092,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[20].Exporter = func(v any, i int) any {
switch v := v.(*GetRequest); i {
case 0:
return &v.state
......@@ -3104,7 +3104,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[21].Exporter = func(v any, i int) any {
switch v := v.(*GetResponse); i {
case 0:
return &v.state
......@@ -3116,7 +3116,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[22].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[22].Exporter = func(v any, i int) any {
switch v := v.(*CapabilityRequest); i {
case 0:
return &v.state
......@@ -3128,7 +3128,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[23].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[23].Exporter = func(v any, i int) any {
switch v := v.(*CapabilityResponse); i {
case 0:
return &v.state
......@@ -3140,7 +3140,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[24].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[24].Exporter = func(v any, i int) any {
switch v := v.(*ModelData); i {
case 0:
return &v.state
......@@ -3153,7 +3153,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
}
}
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[2].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[2].OneofWrappers = []any{
(*TypedValue_StringVal)(nil),
(*TypedValue_IntVal)(nil),
(*TypedValue_UintVal)(nil),
......@@ -3168,12 +3168,12 @@ func file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_init() {
(*TypedValue_AsciiVal)(nil),
(*TypedValue_ProtoBytes)(nil),
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[9].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[9].OneofWrappers = []any{
(*SubscribeRequest_Subscribe)(nil),
(*SubscribeRequest_Poll)(nil),
(*SubscribeRequest_Aliases)(nil),
}
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[11].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_proto_gnmi_gnmi_proto_msgTypes[11].OneofWrappers = []any{
(*SubscribeResponse_Update)(nil),
(*SubscribeResponse_SyncResponse)(nil),
(*SubscribeResponse_Error)(nil),
......
api/go/github.com/openconfig/gnmi/proto/gnmi/gnmi_grpc.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: github.com/openconfig/gnmi/proto/gnmi/gnmi.proto
......@@ -40,8 +40,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
GNMI_Capabilities_FullMethodName = "/gnmi.gNMI/Capabilities"
......@@ -89,8 +89,9 @@ func NewGNMIClient(cc grpc.ClientConnInterface) GNMIClient {
}
func (c *gNMIClient) Capabilities(ctx context.Context, in *CapabilityRequest, opts ...grpc.CallOption) (*CapabilityResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CapabilityResponse)
err := c.cc.Invoke(ctx, GNMI_Capabilities_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, GNMI_Capabilities_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -98,8 +99,9 @@ func (c *gNMIClient) Capabilities(ctx context.Context, in *CapabilityRequest, op
}
func (c *gNMIClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(GetResponse)
err := c.cc.Invoke(ctx, GNMI_Get_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, GNMI_Get_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -107,8 +109,9 @@ func (c *gNMIClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallO
}
func (c *gNMIClient) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(SetResponse)
err := c.cc.Invoke(ctx, GNMI_Set_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, GNMI_Set_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -116,11 +119,12 @@ func (c *gNMIClient) Set(ctx context.Context, in *SetRequest, opts ...grpc.CallO
}
func (c *gNMIClient) Subscribe(ctx context.Context, opts ...grpc.CallOption) (GNMI_SubscribeClient, error) {
stream, err := c.cc.NewStream(ctx, &GNMI_ServiceDesc.Streams[0], GNMI_Subscribe_FullMethodName, opts...)
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &GNMI_ServiceDesc.Streams[0], GNMI_Subscribe_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &gNMISubscribeClient{stream}
x := &gNMISubscribeClient{ClientStream: stream}
return x, nil
}
......@@ -261,7 +265,7 @@ func _GNMI_Set_Handler(srv interface{}, ctx context.Context, dec func(interface{
}
func _GNMI_Subscribe_Handler(srv interface{}, stream grpc.ServerStream) error {
return srv.(GNMIServer).Subscribe(&gNMISubscribeServer{stream})
return srv.(GNMIServer).Subscribe(&gNMISubscribeServer{ServerStream: stream})
}
type GNMI_SubscribeServer interface {
......
api/go/github.com/openconfig/gnmi/proto/gnmi_ext/gnmi_ext.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: github.com/openconfig/gnmi/proto/gnmi_ext/gnmi_ext.proto
......@@ -618,7 +618,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_rawDescGZIP()
var file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes = make([]protoimpl.MessageInfo, 7)
var file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_goTypes = []interface{}{
var file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_goTypes = []any{
(ExtensionID)(0), // 0: gnmi_ext.ExtensionID
(*Extension)(nil), // 1: gnmi_ext.Extension
(*RegisteredExtension)(nil), // 2: gnmi_ext.RegisteredExtension
......@@ -649,7 +649,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Extension); i {
case 0:
return &v.state
......@@ -661,7 +661,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*RegisteredExtension); i {
case 0:
return &v.state
......@@ -673,7 +673,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*MasterArbitration); i {
case 0:
return &v.state
......@@ -685,7 +685,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*Uint128); i {
case 0:
return &v.state
......@@ -697,7 +697,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*Role); i {
case 0:
return &v.state
......@@ -709,7 +709,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*History); i {
case 0:
return &v.state
......@@ -721,7 +721,7 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*TimeRange); i {
case 0:
return &v.state
......@@ -734,12 +734,12 @@ func file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_init() {
}
}
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[0].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[0].OneofWrappers = []any{
(*Extension_RegisteredExt)(nil),
(*Extension_MasterArbitration)(nil),
(*Extension_History)(nil),
}
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[5].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_proto_gnmi_ext_gnmi_ext_proto_msgTypes[5].OneofWrappers = []any{
(*History_SnapshotTime)(nil),
(*History_Range)(nil),
}
......
api/go/github.com/openconfig/gnmi/proto/target/target.pb.go
View file @ bbdaec53
......@@ -16,7 +16,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: github.com/openconfig/gnmi/proto/target/target.proto
......@@ -344,7 +344,7 @@ func file_github_com_openconfig_gnmi_proto_target_target_proto_rawDescGZIP() []b
}
var file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes = make([]protoimpl.MessageInfo, 6)
var file_github_com_openconfig_gnmi_proto_target_target_proto_goTypes = []interface{}{
var file_github_com_openconfig_gnmi_proto_target_target_proto_goTypes = []any{
(*Configuration)(nil), // 0: target.Configuration
(*Target)(nil), // 1: target.Target
(*Credentials)(nil), // 2: target.Credentials
......@@ -373,7 +373,7 @@ func file_github_com_openconfig_gnmi_proto_target_target_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Configuration); i {
case 0:
return &v.state
......@@ -385,7 +385,7 @@ func file_github_com_openconfig_gnmi_proto_target_target_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*Target); i {
case 0:
return &v.state
......@@ -397,7 +397,7 @@ func file_github_com_openconfig_gnmi_proto_target_target_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_proto_target_target_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*Credentials); i {
case 0:
return &v.state
......
api/go/github.com/openconfig/gnmi/testing/fake/proto/fake.pb.go
View file @ bbdaec53
......@@ -4,7 +4,7 @@
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: github.com/openconfig/gnmi/testing/fake/proto/fake.proto
......@@ -2152,7 +2152,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_rawDescGZIP()
var file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_enumTypes = make([]protoimpl.EnumInfo, 2)
var file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes = make([]protoimpl.MessageInfo, 22)
var file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_goTypes = []interface{}{
var file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_goTypes = []any{
(State)(0), // 0: gnmi.fake.State
(Config_ClientType)(0), // 1: gnmi.fake.Config.ClientType
(*Configuration)(nil), // 2: gnmi.fake.Configuration
......@@ -2226,7 +2226,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Configuration); i {
case 0:
return &v.state
......@@ -2238,7 +2238,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*Credentials); i {
case 0:
return &v.state
......@@ -2250,7 +2250,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*Config); i {
case 0:
return &v.state
......@@ -2262,7 +2262,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*FixedGenerator); i {
case 0:
return &v.state
......@@ -2274,7 +2274,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*RandomGenerator); i {
case 0:
return &v.state
......@@ -2286,7 +2286,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*DeleteValue); i {
case 0:
return &v.state
......@@ -2298,7 +2298,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*Value); i {
case 0:
return &v.state
......@@ -2310,7 +2310,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[7].Exporter = func(v any, i int) any {
switch v := v.(*Timestamp); i {
case 0:
return &v.state
......@@ -2322,7 +2322,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[8].Exporter = func(v any, i int) any {
switch v := v.(*IntValue); i {
case 0:
return &v.state
......@@ -2334,7 +2334,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[9].Exporter = func(v any, i int) any {
switch v := v.(*IntRange); i {
case 0:
return &v.state
......@@ -2346,7 +2346,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[10].Exporter = func(v any, i int) any {
switch v := v.(*IntList); i {
case 0:
return &v.state
......@@ -2358,7 +2358,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[11].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[11].Exporter = func(v any, i int) any {
switch v := v.(*DoubleValue); i {
case 0:
return &v.state
......@@ -2370,7 +2370,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[12].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[12].Exporter = func(v any, i int) any {
switch v := v.(*DoubleRange); i {
case 0:
return &v.state
......@@ -2382,7 +2382,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[13].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[13].Exporter = func(v any, i int) any {
switch v := v.(*DoubleList); i {
case 0:
return &v.state
......@@ -2394,7 +2394,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[14].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[14].Exporter = func(v any, i int) any {
switch v := v.(*StringValue); i {
case 0:
return &v.state
......@@ -2406,7 +2406,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[15].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[15].Exporter = func(v any, i int) any {
switch v := v.(*StringList); i {
case 0:
return &v.state
......@@ -2418,7 +2418,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[16].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[16].Exporter = func(v any, i int) any {
switch v := v.(*StringListValue); i {
case 0:
return &v.state
......@@ -2430,7 +2430,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[17].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[17].Exporter = func(v any, i int) any {
switch v := v.(*BoolValue); i {
case 0:
return &v.state
......@@ -2442,7 +2442,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[18].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[18].Exporter = func(v any, i int) any {
switch v := v.(*BoolList); i {
case 0:
return &v.state
......@@ -2454,7 +2454,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[19].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[19].Exporter = func(v any, i int) any {
switch v := v.(*UintValue); i {
case 0:
return &v.state
......@@ -2466,7 +2466,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[20].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[20].Exporter = func(v any, i int) any {
switch v := v.(*UintRange); i {
case 0:
return &v.state
......@@ -2478,7 +2478,7 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
return nil
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[21].Exporter = func(v interface{}, i int) interface{} {
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[21].Exporter = func(v any, i int) any {
switch v := v.(*UintList); i {
case 0:
return &v.state
......@@ -2491,12 +2491,12 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
}
}
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[2].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[2].OneofWrappers = []any{
(*Config_Custom)(nil),
(*Config_Random)(nil),
(*Config_Fixed)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[6].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[6].OneofWrappers = []any{
(*Value_IntValue)(nil),
(*Value_DoubleValue)(nil),
(*Value_StringValue)(nil),
......@@ -2506,24 +2506,24 @@ func file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_init() {
(*Value_UintValue)(nil),
(*Value_StringListValue)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[8].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[8].OneofWrappers = []any{
(*IntValue_Range)(nil),
(*IntValue_List)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[11].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[11].OneofWrappers = []any{
(*DoubleValue_Range)(nil),
(*DoubleValue_List)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[14].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[14].OneofWrappers = []any{
(*StringValue_List)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[16].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[16].OneofWrappers = []any{
(*StringListValue_List)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[17].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[17].OneofWrappers = []any{
(*BoolValue_List)(nil),
}
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[19].OneofWrappers = []interface{}{
file_github_com_openconfig_gnmi_testing_fake_proto_fake_proto_msgTypes[19].OneofWrappers = []any{
(*UintValue_Range)(nil),
(*UintValue_List)(nil),
}
......
api/go/github.com/openconfig/gnmi/testing/fake/proto/fake_grpc.pb.go
View file @ bbdaec53
......@@ -4,7 +4,7 @@
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: github.com/openconfig/gnmi/testing/fake/proto/fake.proto
......@@ -19,8 +19,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
AgentManager_Add_FullMethodName = "/gnmi.fake.AgentManager/Add"
......@@ -49,8 +49,9 @@ func NewAgentManagerClient(cc grpc.ClientConnInterface) AgentManagerClient {
}
func (c *agentManagerClient) Add(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Config, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Config)
err := c.cc.Invoke(ctx, AgentManager_Add_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AgentManager_Add_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -58,8 +59,9 @@ func (c *agentManagerClient) Add(ctx context.Context, in *Config, opts ...grpc.C
}
func (c *agentManagerClient) Remove(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Config, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Config)
err := c.cc.Invoke(ctx, AgentManager_Remove_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AgentManager_Remove_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -67,8 +69,9 @@ func (c *agentManagerClient) Remove(ctx context.Context, in *Config, opts ...grp
}
func (c *agentManagerClient) Status(ctx context.Context, in *Config, opts ...grpc.CallOption) (*Config, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Config)
err := c.cc.Invoke(ctx, AgentManager_Status_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AgentManager_Status_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......
api/go/gosdn/app/app.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: gosdn/app/app.proto
......@@ -313,7 +313,7 @@ func file_gosdn_app_app_proto_rawDescGZIP() []byte {
}
var file_gosdn_app_app_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_gosdn_app_app_proto_goTypes = []interface{}{
var file_gosdn_app_app_proto_goTypes = []any{
(*AppRegisterRequest)(nil), // 0: gosdn.app.AppRegisterRequest
(*AppRegisterResponse)(nil), // 1: gosdn.app.AppRegisterResponse
(*AppDeregisterRequest)(nil), // 2: gosdn.app.AppDeregisterRequest
......@@ -337,7 +337,7 @@ func file_gosdn_app_app_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_gosdn_app_app_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_app_app_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*AppRegisterRequest); i {
case 0:
return &v.state
......@@ -349,7 +349,7 @@ func file_gosdn_app_app_proto_init() {
return nil
}
}
file_gosdn_app_app_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_app_app_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*AppRegisterResponse); i {
case 0:
return &v.state
......@@ -361,7 +361,7 @@ func file_gosdn_app_app_proto_init() {
return nil
}
}
file_gosdn_app_app_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_app_app_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*AppDeregisterRequest); i {
case 0:
return &v.state
......@@ -373,7 +373,7 @@ func file_gosdn_app_app_proto_init() {
return nil
}
}
file_gosdn_app_app_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_app_app_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*AppDeregisterResponse); i {
case 0:
return &v.state
......
api/go/gosdn/app/app.pb.gw.go
View file @ bbdaec53
......@@ -145,21 +145,21 @@ func RegisterAppServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux,
// RegisterAppServiceHandlerFromEndpoint is same as RegisterAppServiceHandler but
// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterAppServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
conn, err := grpc.DialContext(ctx, endpoint, opts...)
conn, err := grpc.NewClient(endpoint, opts...)
if err != nil {
return err
}
defer func() {
if err != nil {
if cerr := conn.Close(); cerr != nil {
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
}
return
}
go func() {
<-ctx.Done()
if cerr := conn.Close(); cerr != nil {
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
}
}()
}()
......
api/go/gosdn/app/app_grpc.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: gosdn/app/app.proto
......@@ -15,8 +15,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
AppService_Register_FullMethodName = "/gosdn.app.AppService/Register"
......@@ -42,8 +42,9 @@ func NewAppServiceClient(cc grpc.ClientConnInterface) AppServiceClient {
}
func (c *appServiceClient) Register(ctx context.Context, in *AppRegisterRequest, opts ...grpc.CallOption) (*AppRegisterResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AppRegisterResponse)
err := c.cc.Invoke(ctx, AppService_Register_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AppService_Register_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -51,8 +52,9 @@ func (c *appServiceClient) Register(ctx context.Context, in *AppRegisterRequest,
}
func (c *appServiceClient) Deregister(ctx context.Context, in *AppDeregisterRequest, opts ...grpc.CallOption) (*AppDeregisterResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(AppDeregisterResponse)
err := c.cc.Invoke(ctx, AppService_Deregister_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, AppService_Deregister_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......
api/go/gosdn/configurationmanagement/configurationmanagement.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: gosdn/configurationmanagement/configurationmanagement.proto
......@@ -320,7 +320,7 @@ func file_gosdn_configurationmanagement_configurationmanagement_proto_rawDescGZI
}
var file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes = make([]protoimpl.MessageInfo, 4)
var file_gosdn_configurationmanagement_configurationmanagement_proto_goTypes = []interface{}{
var file_gosdn_configurationmanagement_configurationmanagement_proto_goTypes = []any{
(*ExportSDNConfigRequest)(nil), // 0: gosdn.configurationmanagement.ExportSDNConfigRequest
(*ExportSDNConfigResponse)(nil), // 1: gosdn.configurationmanagement.ExportSDNConfigResponse
(*ImportSDNConfigRequest)(nil), // 2: gosdn.configurationmanagement.ImportSDNConfigRequest
......@@ -344,7 +344,7 @@ func file_gosdn_configurationmanagement_configurationmanagement_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*ExportSDNConfigRequest); i {
case 0:
return &v.state
......@@ -356,7 +356,7 @@ func file_gosdn_configurationmanagement_configurationmanagement_proto_init() {
return nil
}
}
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*ExportSDNConfigResponse); i {
case 0:
return &v.state
......@@ -368,7 +368,7 @@ func file_gosdn_configurationmanagement_configurationmanagement_proto_init() {
return nil
}
}
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*ImportSDNConfigRequest); i {
case 0:
return &v.state
......@@ -380,7 +380,7 @@ func file_gosdn_configurationmanagement_configurationmanagement_proto_init() {
return nil
}
}
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_configurationmanagement_configurationmanagement_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*ImportSDNConfigResponse); i {
case 0:
return &v.state
......
api/go/gosdn/configurationmanagement/configurationmanagement.pb.gw.go
View file @ bbdaec53
......@@ -233,21 +233,21 @@ func RegisterConfigurationManagementServiceHandlerServer(ctx context.Context, mu
// RegisterConfigurationManagementServiceHandlerFromEndpoint is same as RegisterConfigurationManagementServiceHandler but
// automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterConfigurationManagementServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error) {
conn, err := grpc.DialContext(ctx, endpoint, opts...)
conn, err := grpc.NewClient(endpoint, opts...)
if err != nil {
return err
}
defer func() {
if err != nil {
if cerr := conn.Close(); cerr != nil {
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
}
return
}
go func() {
<-ctx.Done()
if cerr := conn.Close(); cerr != nil {
grpclog.Infof("Failed to close conn to %s: %v", endpoint, cerr)
grpclog.Errorf("Failed to close conn to %s: %v", endpoint, cerr)
}
}()
}()
......
api/go/gosdn/configurationmanagement/configurationmanagement_grpc.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: gosdn/configurationmanagement/configurationmanagement.proto
......@@ -15,8 +15,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
ConfigurationManagementService_ExportSDNConfig_FullMethodName = "/gosdn.configurationmanagement.ConfigurationManagementService/ExportSDNConfig"
......@@ -26,6 +26,8 @@ const (
// ConfigurationManagementServiceClient is the client API for ConfigurationManagementService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
//
// The ConfigurationManagementService allows to access configurations
type ConfigurationManagementServiceClient interface {
// Allows for export of the whole SDN configuration
ExportSDNConfig(ctx context.Context, in *ExportSDNConfigRequest, opts ...grpc.CallOption) (*ExportSDNConfigResponse, error)
......@@ -42,8 +44,9 @@ func NewConfigurationManagementServiceClient(cc grpc.ClientConnInterface) Config
}
func (c *configurationManagementServiceClient) ExportSDNConfig(ctx context.Context, in *ExportSDNConfigRequest, opts ...grpc.CallOption) (*ExportSDNConfigResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ExportSDNConfigResponse)
err := c.cc.Invoke(ctx, ConfigurationManagementService_ExportSDNConfig_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, ConfigurationManagementService_ExportSDNConfig_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -51,8 +54,9 @@ func (c *configurationManagementServiceClient) ExportSDNConfig(ctx context.Conte
}
func (c *configurationManagementServiceClient) ImportSDNConfig(ctx context.Context, in *ImportSDNConfigRequest, opts ...grpc.CallOption) (*ImportSDNConfigResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(ImportSDNConfigResponse)
err := c.cc.Invoke(ctx, ConfigurationManagementService_ImportSDNConfig_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, ConfigurationManagementService_ImportSDNConfig_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -62,6 +66,8 @@ func (c *configurationManagementServiceClient) ImportSDNConfig(ctx context.Conte
// ConfigurationManagementServiceServer is the server API for ConfigurationManagementService service.
// All implementations must embed UnimplementedConfigurationManagementServiceServer
// for forward compatibility
//
// The ConfigurationManagementService allows to access configurations
type ConfigurationManagementServiceServer interface {
// Allows for export of the whole SDN configuration
ExportSDNConfig(context.Context, *ExportSDNConfigRequest) (*ExportSDNConfigResponse, error)
......
api/go/gosdn/conflict/conflict.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: gosdn/conflict/conflict.proto
......@@ -99,7 +99,7 @@ func file_gosdn_conflict_conflict_proto_rawDescGZIP() []byte {
}
var file_gosdn_conflict_conflict_proto_msgTypes = make([]protoimpl.MessageInfo, 1)
var file_gosdn_conflict_conflict_proto_goTypes = []interface{}{
var file_gosdn_conflict_conflict_proto_goTypes = []any{
(*Metadata)(nil), // 0: gosdn.conflict.Metadata
}
var file_gosdn_conflict_conflict_proto_depIdxs = []int32{
......@@ -116,7 +116,7 @@ func file_gosdn_conflict_conflict_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_gosdn_conflict_conflict_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_conflict_conflict_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Metadata); i {
case 0:
return &v.state
......
api/go/gosdn/csbi/csbi.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go. DO NOT EDIT.
// versions:
// protoc-gen-go v1.32.0
// protoc-gen-go v1.34.2
// protoc (unknown)
// source: gosdn/csbi/csbi.proto
......@@ -824,7 +824,7 @@ func file_gosdn_csbi_csbi_proto_rawDescGZIP() []byte {
var file_gosdn_csbi_csbi_proto_enumTypes = make([]protoimpl.EnumInfo, 1)
var file_gosdn_csbi_csbi_proto_msgTypes = make([]protoimpl.MessageInfo, 11)
var file_gosdn_csbi_csbi_proto_goTypes = []interface{}{
var file_gosdn_csbi_csbi_proto_goTypes = []any{
(State)(0), // 0: gosdn.csbi.State
(*Syn)(nil), // 1: gosdn.csbi.Syn
(*Ack)(nil), // 2: gosdn.csbi.Ack
......@@ -870,7 +870,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return
}
if !protoimpl.UnsafeEnabled {
file_gosdn_csbi_csbi_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[0].Exporter = func(v any, i int) any {
switch v := v.(*Syn); i {
case 0:
return &v.state
......@@ -882,7 +882,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[1].Exporter = func(v any, i int) any {
switch v := v.(*Ack); i {
case 0:
return &v.state
......@@ -894,7 +894,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[2].Exporter = func(v any, i int) any {
switch v := v.(*GetRequest); i {
case 0:
return &v.state
......@@ -906,7 +906,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[3].Exporter = func(v any, i int) any {
switch v := v.(*GetPayloadRequest); i {
case 0:
return &v.state
......@@ -918,7 +918,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[4].Exporter = func(v any, i int) any {
switch v := v.(*GetResponse); i {
case 0:
return &v.state
......@@ -930,7 +930,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[5].Exporter = func(v any, i int) any {
switch v := v.(*Deployment); i {
case 0:
return &v.state
......@@ -942,7 +942,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[6].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[6].Exporter = func(v any, i int) any {
switch v := v.(*CreateRequest); i {
case 0:
return &v.state
......@@ -954,7 +954,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[7].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[7].Exporter = func(v any, i int) any {
switch v := v.(*CreateResponse); i {
case 0:
return &v.state
......@@ -966,7 +966,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[8].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[8].Exporter = func(v any, i int) any {
switch v := v.(*Payload); i {
case 0:
return &v.state
......@@ -978,7 +978,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[9].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[9].Exporter = func(v any, i int) any {
switch v := v.(*DeleteRequest); i {
case 0:
return &v.state
......@@ -990,7 +990,7 @@ func file_gosdn_csbi_csbi_proto_init() {
return nil
}
}
file_gosdn_csbi_csbi_proto_msgTypes[10].Exporter = func(v interface{}, i int) interface{} {
file_gosdn_csbi_csbi_proto_msgTypes[10].Exporter = func(v any, i int) any {
switch v := v.(*DeleteResponse); i {
case 0:
return &v.state
......
api/go/gosdn/csbi/csbi_grpc.pb.go
View file @ bbdaec53
// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
// versions:
// - protoc-gen-go-grpc v1.3.0
// - protoc-gen-go-grpc v1.4.0
// - protoc (unknown)
// source: gosdn/csbi/csbi.proto
......@@ -15,8 +15,8 @@ import (
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
// Requires gRPC-Go v1.32.0 or later.
const _ = grpc.SupportPackageIsVersion7
// Requires gRPC-Go v1.62.0 or later.
const _ = grpc.SupportPackageIsVersion8
const (
CsbiService_Get_FullMethodName = "/gosdn.csbi.CsbiService/Get"
......@@ -30,6 +30,9 @@ const (
// CsbiServiceClient is the client API for CsbiService service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
//
// only used from within the controller; therefore we do not provide
// grpc-gateway definitions
type CsbiServiceClient interface {
Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
GetFile(ctx context.Context, in *GetPayloadRequest, opts ...grpc.CallOption) (CsbiService_GetFileClient, error)
......@@ -48,8 +51,9 @@ func NewCsbiServiceClient(cc grpc.ClientConnInterface) CsbiServiceClient {
}
func (c *csbiServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(GetResponse)
err := c.cc.Invoke(ctx, CsbiService_Get_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, CsbiService_Get_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -57,11 +61,12 @@ func (c *csbiServiceClient) Get(ctx context.Context, in *GetRequest, opts ...grp
}
func (c *csbiServiceClient) GetFile(ctx context.Context, in *GetPayloadRequest, opts ...grpc.CallOption) (CsbiService_GetFileClient, error) {
stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[0], CsbiService_GetFile_FullMethodName, opts...)
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
stream, err := c.cc.NewStream(ctx, &CsbiService_ServiceDesc.Streams[0], CsbiService_GetFile_FullMethodName, cOpts...)
if err != nil {
return nil, err
}
x := &csbiServiceGetFileClient{stream}
x := &csbiServiceGetFileClient{ClientStream: stream}
if err := x.ClientStream.SendMsg(in); err != nil {
return nil, err
}
......@@ -89,8 +94,9 @@ func (x *csbiServiceGetFileClient) Recv() (*Payload, error) {
}
func (c *csbiServiceClient) Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CreateResponse)
err := c.cc.Invoke(ctx, CsbiService_Create_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, CsbiService_Create_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -98,8 +104,9 @@ func (c *csbiServiceClient) Create(ctx context.Context, in *CreateRequest, opts
}
func (c *csbiServiceClient) CreateGoStruct(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(CreateResponse)
err := c.cc.Invoke(ctx, CsbiService_CreateGoStruct_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, CsbiService_CreateGoStruct_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -107,8 +114,9 @@ func (c *csbiServiceClient) CreateGoStruct(ctx context.Context, in *CreateReques
}
func (c *csbiServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(DeleteResponse)
err := c.cc.Invoke(ctx, CsbiService_Delete_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, CsbiService_Delete_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -116,8 +124,9 @@ func (c *csbiServiceClient) Delete(ctx context.Context, in *DeleteRequest, opts
}
func (c *csbiServiceClient) Hello(ctx context.Context, in *Syn, opts ...grpc.CallOption) (*Ack, error) {
cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...)
out := new(Ack)
err := c.cc.Invoke(ctx, CsbiService_Hello_FullMethodName, in, out, opts...)
err := c.cc.Invoke(ctx, CsbiService_Hello_FullMethodName, in, out, cOpts...)
if err != nil {
return nil, err
}
......@@ -127,6 +136,9 @@ func (c *csbiServiceClient) Hello(ctx context.Context, in *Syn, opts ...grpc.Cal
// CsbiServiceServer is the server API for CsbiService service.
// All implementations must embed UnimplementedCsbiServiceServer
// for forward compatibility
//
// only used from within the controller; therefore we do not provide
// grpc-gateway definitions
type CsbiServiceServer interface {
Get(context.Context, *GetRequest) (*GetResponse, error)
GetFile(*GetPayloadRequest, CsbiService_GetFileServer) error
......@@ -195,7 +207,7 @@ func _CsbiService_GetFile_Handler(srv interface{}, stream grpc.ServerStream) err
if err := stream.RecvMsg(m); err != nil {
return err
}
return srv.(CsbiServiceServer).GetFile(m, &csbiServiceGetFileServer{stream})
return srv.(CsbiServiceServer).GetFile(m, &csbiServiceGetFileServer{ServerStream: stream})
}
type CsbiService_GetFileServer interface {
......