diff options
Diffstat (limited to 'api/gobgp.pb.go')
| -rw-r--r-- | api/gobgp.pb.go | 68 |
1 files changed, 64 insertions, 4 deletions
diff --git a/api/gobgp.pb.go b/api/gobgp.pb.go index 7d01de14..7aeb6e26 100644 --- a/api/gobgp.pb.go +++ b/api/gobgp.pb.go @@ -1182,6 +1182,7 @@ type GrpcClient interface { GetNeighbor(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Peer, error) GetRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (Grpc_GetRibClient, error) GetAdjRib(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (Grpc_GetAdjRibClient, error) + MonitorBestChanged(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (Grpc_MonitorBestChangedClient, error) Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) SoftReset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) SoftResetIn(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) @@ -1310,6 +1311,38 @@ func (x *grpcGetAdjRibClient) Recv() (*Path, error) { return m, nil } +func (c *grpcClient) MonitorBestChanged(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (Grpc_MonitorBestChangedClient, error) { + stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[3], c.cc, "/api.Grpc/MonitorBestChanged", opts...) + if err != nil { + return nil, err + } + x := &grpcMonitorBestChangedClient{stream} + if err := x.ClientStream.SendMsg(in); err != nil { + return nil, err + } + if err := x.ClientStream.CloseSend(); err != nil { + return nil, err + } + return x, nil +} + +type Grpc_MonitorBestChangedClient interface { + Recv() (*Path, error) + grpc.ClientStream +} + +type grpcMonitorBestChangedClient struct { + grpc.ClientStream +} + +func (x *grpcMonitorBestChangedClient) Recv() (*Path, error) { + m := new(Path) + if err := x.ClientStream.RecvMsg(m); err != nil { + return nil, err + } + return m, nil +} + func (c *grpcClient) Reset(ctx context.Context, in *Arguments, opts ...grpc.CallOption) (*Error, error) { out := new(Error) err := grpc.Invoke(ctx, "/api.Grpc/Reset", in, out, c.cc, opts...) @@ -1374,7 +1407,7 @@ func (c *grpcClient) Disable(ctx context.Context, in *Arguments, opts ...grpc.Ca } func (c *grpcClient) ModPath(ctx context.Context, opts ...grpc.CallOption) (Grpc_ModPathClient, error) { - stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[3], c.cc, "/api.Grpc/ModPath", opts...) + stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[4], c.cc, "/api.Grpc/ModPath", opts...) if err != nil { return nil, err } @@ -1417,7 +1450,7 @@ func (c *grpcClient) GetNeighborPolicy(ctx context.Context, in *Arguments, opts } func (c *grpcClient) ModNeighborPolicy(ctx context.Context, opts ...grpc.CallOption) (Grpc_ModNeighborPolicyClient, error) { - stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[4], c.cc, "/api.Grpc/ModNeighborPolicy", opts...) + stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[5], c.cc, "/api.Grpc/ModNeighborPolicy", opts...) if err != nil { return nil, err } @@ -1448,7 +1481,7 @@ func (x *grpcModNeighborPolicyClient) Recv() (*Error, error) { } func (c *grpcClient) GetPolicyRoutePolicies(ctx context.Context, in *PolicyArguments, opts ...grpc.CallOption) (Grpc_GetPolicyRoutePoliciesClient, error) { - stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[5], c.cc, "/api.Grpc/GetPolicyRoutePolicies", opts...) + stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[6], c.cc, "/api.Grpc/GetPolicyRoutePolicies", opts...) if err != nil { return nil, err } @@ -1489,7 +1522,7 @@ func (c *grpcClient) GetPolicyRoutePolicy(ctx context.Context, in *PolicyArgumen } func (c *grpcClient) ModPolicyRoutePolicy(ctx context.Context, opts ...grpc.CallOption) (Grpc_ModPolicyRoutePolicyClient, error) { - stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[6], c.cc, "/api.Grpc/ModPolicyRoutePolicy", opts...) + stream, err := grpc.NewClientStream(ctx, &_Grpc_serviceDesc.Streams[7], c.cc, "/api.Grpc/ModPolicyRoutePolicy", opts...) if err != nil { return nil, err } @@ -1526,6 +1559,7 @@ type GrpcServer interface { GetNeighbor(context.Context, *Arguments) (*Peer, error) GetRib(*Arguments, Grpc_GetRibServer) error GetAdjRib(*Arguments, Grpc_GetAdjRibServer) error + MonitorBestChanged(*Arguments, Grpc_MonitorBestChangedServer) error Reset(context.Context, *Arguments) (*Error, error) SoftReset(context.Context, *Arguments) (*Error, error) SoftResetIn(context.Context, *Arguments) (*Error, error) @@ -1620,6 +1654,27 @@ func (x *grpcGetAdjRibServer) Send(m *Path) error { return x.ServerStream.SendMsg(m) } +func _Grpc_MonitorBestChanged_Handler(srv interface{}, stream grpc.ServerStream) error { + m := new(Arguments) + if err := stream.RecvMsg(m); err != nil { + return err + } + return srv.(GrpcServer).MonitorBestChanged(m, &grpcMonitorBestChangedServer{stream}) +} + +type Grpc_MonitorBestChangedServer interface { + Send(*Path) error + grpc.ServerStream +} + +type grpcMonitorBestChangedServer struct { + grpc.ServerStream +} + +func (x *grpcMonitorBestChangedServer) Send(m *Path) error { + return x.ServerStream.SendMsg(m) +} + func _Grpc_Reset_Handler(srv interface{}, ctx context.Context, codec grpc.Codec, buf []byte) (interface{}, error) { in := new(Arguments) if err := codec.Unmarshal(buf, in); err != nil { @@ -1889,6 +1944,11 @@ var _Grpc_serviceDesc = grpc.ServiceDesc{ ServerStreams: true, }, { + StreamName: "MonitorBestChanged", + Handler: _Grpc_MonitorBestChanged_Handler, + ServerStreams: true, + }, + { StreamName: "ModPath", Handler: _Grpc_ModPath_Handler, ClientStreams: true, |