Documentation ¶
Index ¶
- func RegisterDataplaneServer(s *grpc.Server, srv DataplaneServer)
- func RegisterMechanismsMonitorServer(s *grpc.Server, srv MechanismsMonitorServer)
- type DataplaneClient
- type DataplaneServer
- type MechanismUpdate
- func (*MechanismUpdate) Descriptor() ([]byte, []int)
- func (m *MechanismUpdate) GetLocalMechanisms() []*connection1.Mechanism
- func (m *MechanismUpdate) GetRemoteMechanisms() []*connection.Mechanism
- func (*MechanismUpdate) ProtoMessage()
- func (m *MechanismUpdate) Reset()
- func (m *MechanismUpdate) String() string
- func (m *MechanismUpdate) XXX_DiscardUnknown()
- func (m *MechanismUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MechanismUpdate) XXX_Merge(src proto.Message)
- func (m *MechanismUpdate) XXX_Size() int
- func (m *MechanismUpdate) XXX_Unmarshal(b []byte) error
- type MechanismsMonitorClient
- type MechanismsMonitorServer
- type MechanismsMonitor_MonitorMechanismsClient
- type MechanismsMonitor_MonitorMechanismsServer
- type UnimplementedDataplaneServer
- type UnimplementedMechanismsMonitorServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDataplaneServer ¶
func RegisterDataplaneServer(s *grpc.Server, srv DataplaneServer)
func RegisterMechanismsMonitorServer ¶
func RegisterMechanismsMonitorServer(s *grpc.Server, srv MechanismsMonitorServer)
Types ¶
type DataplaneClient ¶
type DataplaneClient interface { Request(ctx context.Context, in *crossconnect.CrossConnect, opts ...grpc.CallOption) (*crossconnect.CrossConnect, error) Close(ctx context.Context, in *crossconnect.CrossConnect, opts ...grpc.CallOption) (*empty.Empty, error) }
DataplaneClient is the client API for Dataplane service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDataplaneClient ¶
func NewDataplaneClient(cc *grpc.ClientConn) DataplaneClient
type DataplaneServer ¶
type DataplaneServer interface { Request(context.Context, *crossconnect.CrossConnect) (*crossconnect.CrossConnect, error) Close(context.Context, *crossconnect.CrossConnect) (*empty.Empty, error) }
DataplaneServer is the server API for Dataplane service.
type MechanismUpdate ¶
type MechanismUpdate struct { RemoteMechanisms []*connection.Mechanism `protobuf:"bytes,1,rep,name=remote_mechanisms,json=remoteMechanisms,proto3" json:"remote_mechanisms,omitempty"` LocalMechanisms []*connection1.Mechanism `protobuf:"bytes,2,rep,name=local_mechanisms,json=localMechanisms,proto3" json:"local_mechanisms,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
Message sent by dataplane module informing NSM of any changes in its operations parameters or constraints
func (*MechanismUpdate) Descriptor ¶
func (*MechanismUpdate) Descriptor() ([]byte, []int)
func (*MechanismUpdate) GetLocalMechanisms ¶
func (m *MechanismUpdate) GetLocalMechanisms() []*connection1.Mechanism
func (*MechanismUpdate) GetRemoteMechanisms ¶
func (m *MechanismUpdate) GetRemoteMechanisms() []*connection.Mechanism
func (*MechanismUpdate) ProtoMessage ¶
func (*MechanismUpdate) ProtoMessage()
func (*MechanismUpdate) Reset ¶
func (m *MechanismUpdate) Reset()
func (*MechanismUpdate) String ¶
func (m *MechanismUpdate) String() string
func (*MechanismUpdate) XXX_DiscardUnknown ¶
func (m *MechanismUpdate) XXX_DiscardUnknown()
func (*MechanismUpdate) XXX_Marshal ¶
func (m *MechanismUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MechanismUpdate) XXX_Merge ¶
func (m *MechanismUpdate) XXX_Merge(src proto.Message)
func (*MechanismUpdate) XXX_Size ¶
func (m *MechanismUpdate) XXX_Size() int
func (*MechanismUpdate) XXX_Unmarshal ¶
func (m *MechanismUpdate) XXX_Unmarshal(b []byte) error
type MechanismsMonitorClient ¶
type MechanismsMonitorClient interface {
MonitorMechanisms(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (MechanismsMonitor_MonitorMechanismsClient, error)
}
MechanismsMonitorClient is the client API for MechanismsMonitor service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewMechanismsMonitorClient ¶
func NewMechanismsMonitorClient(cc *grpc.ClientConn) MechanismsMonitorClient
type MechanismsMonitorServer ¶
type MechanismsMonitorServer interface {
MonitorMechanisms(*empty.Empty, MechanismsMonitor_MonitorMechanismsServer) error
}
MechanismsMonitorServer is the server API for MechanismsMonitor service.
type MechanismsMonitor_MonitorMechanismsClient ¶
type MechanismsMonitor_MonitorMechanismsClient interface { Recv() (*MechanismUpdate, error) grpc.ClientStream }
type MechanismsMonitor_MonitorMechanismsServer ¶
type MechanismsMonitor_MonitorMechanismsServer interface { Send(*MechanismUpdate) error grpc.ServerStream }
type UnimplementedDataplaneServer ¶
type UnimplementedDataplaneServer struct { }
UnimplementedDataplaneServer can be embedded to have forward compatible implementations.
func (*UnimplementedDataplaneServer) Close ¶
func (*UnimplementedDataplaneServer) Close(ctx context.Context, req *crossconnect.CrossConnect) (*empty.Empty, error)
func (*UnimplementedDataplaneServer) Request ¶
func (*UnimplementedDataplaneServer) Request(ctx context.Context, req *crossconnect.CrossConnect) (*crossconnect.CrossConnect, error)
type UnimplementedMechanismsMonitorServer ¶
type UnimplementedMechanismsMonitorServer struct { }
UnimplementedMechanismsMonitorServer can be embedded to have forward compatible implementations.
func (*UnimplementedMechanismsMonitorServer) MonitorMechanisms ¶
func (*UnimplementedMechanismsMonitorServer) MonitorMechanisms(req *empty.Empty, srv MechanismsMonitor_MonitorMechanismsServer) error