msm_stub

Documentation

Index

• Variables
• func RegisterMsmControlPlaneServer(s grpc.ServiceRegistrar, srv MsmControlPlaneServer)
• type Event
  • func (Event) Descriptor() protoreflect.EnumDescriptor
  • func (x Event) Enum() *Event
  • func (Event) EnumDescriptor() ([]byte, []int)
  • func (x Event) Number() protoreflect.EnumNumber
  • func (x Event) String() string
  • func (Event) Type() protoreflect.EnumType
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (x *Message) GetData() string
  • func (x *Message) GetEvent() Event
  • func (x *Message) GetLocal() string
  • func (x *Message) GetRemote() string
  • func (*Message) ProtoMessage()
  • func (x *Message) ProtoReflect() protoreflect.Message
  • func (x *Message) Reset()
  • func (x *Message) String() string
• type MsmControlPlaneClient
  • func NewMsmControlPlaneClient(cc grpc.ClientConnInterface) MsmControlPlaneClient
• type MsmControlPlaneServer
• type MsmControlPlane_SendClient
• type MsmControlPlane_SendServer
• type UnimplementedMsmControlPlaneServer
  • func (UnimplementedMsmControlPlaneServer) Send(MsmControlPlane_SendServer) error
• type UnsafeMsmControlPlaneServer

Variables

var (
	Event_name = map[int32]string{
		0: "REGISTER",
		1: "CONFIG",
		2: "REQUEST",
		3: "ADD",
		4: "DELETE",
		5: "DATA",
	}
	Event_value = map[string]int32{
		"REGISTER": 0,
		"CONFIG":   1,
		"REQUEST":  2,
		"ADD":      3,
		"DELETE":   4,
		"DATA":     5,
	}
)

Enum value maps for Event.

var File_msm_stub_proto protoreflect.FileDescriptor

var MsmControlPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "msm_cp.MsmControlPlane",
	HandlerType: (*MsmControlPlaneServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Send",
			Handler:       _MsmControlPlane_Send_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "msm_stub.proto",
}

MsmControlPlane_ServiceDesc is the grpc.ServiceDesc for MsmControlPlane service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMsmControlPlaneServer

func RegisterMsmControlPlaneServer(s grpc.ServiceRegistrar, srv MsmControlPlaneServer)

Types

type Event

type Event int32

const (
	Event_REGISTER Event = 0
	Event_CONFIG   Event = 1
	Event_REQUEST  Event = 2
	Event_ADD      Event = 3
	Event_DELETE   Event = 4
	Event_DATA     Event = 5
)

func (Event) Descriptor

func (Event) Descriptor() protoreflect.EnumDescriptor

func (Event) Enum

func (x Event) Enum() *Event

func (Event) EnumDescriptor

func (Event) EnumDescriptor() ([]byte, []int)

Deprecated: Use Event.Descriptor instead.

func (Event) Number

func (x Event) Number() protoreflect.EnumNumber

func (Event) String

func (x Event) String() string

func (Event) Type

func (Event) Type() protoreflect.EnumType

type Message

type Message struct {
	Event  Event  `protobuf:"varint,1,opt,name=event,proto3,enum=msm_cp.Event" json:"event,omitempty"`
	Local  string `protobuf:"bytes,2,opt,name=local,proto3" json:"local,omitempty"`
	Remote string `protobuf:"bytes,3,opt,name=remote,proto3" json:"remote,omitempty"`
	Data   string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor

func (*Message) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData

func (x *Message) GetData() string

func (*Message) GetEvent

func (x *Message) GetEvent() Event

func (*Message) GetLocal

func (x *Message) GetLocal() string

func (*Message) GetRemote

func (x *Message) GetRemote() string

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

type MsmControlPlaneClient

type MsmControlPlaneClient interface {
	Send(ctx context.Context, opts ...grpc.CallOption) (MsmControlPlane_SendClient, error)
}

MsmControlPlaneClient is the client API for MsmControlPlane 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.

func NewMsmControlPlaneClient

func NewMsmControlPlaneClient(cc grpc.ClientConnInterface) MsmControlPlaneClient

type MsmControlPlaneServer

type MsmControlPlaneServer interface {
	Send(MsmControlPlane_SendServer) error
}

MsmControlPlaneServer is the server API for MsmControlPlane service. All implementations should embed UnimplementedMsmControlPlaneServer for forward compatibility

type MsmControlPlane_SendClient

type MsmControlPlane_SendClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type MsmControlPlane_SendServer

type MsmControlPlane_SendServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type UnimplementedMsmControlPlaneServer

type UnimplementedMsmControlPlaneServer struct {
}

UnimplementedMsmControlPlaneServer should be embedded to have forward compatible implementations.

func (UnimplementedMsmControlPlaneServer) Send

func (UnimplementedMsmControlPlaneServer) Send(MsmControlPlane_SendServer) error

type UnsafeMsmControlPlaneServer

type UnsafeMsmControlPlaneServer interface {
	// contains filtered or unexported methods
}

UnsafeMsmControlPlaneServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsmControlPlaneServer will result in compilation errors.