proto

Documentation

Index

• func RegisterDatatunnelControllerServer(s *grpc.Server, srv DatatunnelControllerServer)
• type ControlStreamData
  • func (*ControlStreamData) Descriptor() ([]byte, []int)
  • func (m *ControlStreamData) GetAction() string
  • func (m *ControlStreamData) GetActionValue() string
  • func (m *ControlStreamData) GetVersion() int32
  • func (*ControlStreamData) ProtoMessage()
  • func (m *ControlStreamData) Reset()
  • func (m *ControlStreamData) String() string
  • func (m *ControlStreamData) XXX_DiscardUnknown()
  • func (m *ControlStreamData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (dst *ControlStreamData) XXX_Merge(src proto.Message)
  • func (m *ControlStreamData) XXX_Size() int
  • func (m *ControlStreamData) XXX_Unmarshal(b []byte) error
• type DatatunnelControllerClient
  • func NewDatatunnelControllerClient(cc grpc.ClientConnInterface) DatatunnelControllerClient
• type DatatunnelControllerServer
• type DatatunnelController_ControlStreamClient
• type DatatunnelController_ControlStreamServer
• type UnimplementedDatatunnelControllerServer
  • func (UnimplementedDatatunnelControllerServer) ControlStream(DatatunnelController_ControlStreamServer) error
• type UnsafeDatatunnelControllerServer

Functions

func RegisterDatatunnelControllerServer

func RegisterDatatunnelControllerServer(s *grpc.Server, srv DatatunnelControllerServer)

Types

type ControlStreamData

type ControlStreamData struct {
	Version              int32    `protobuf:"varint,1,opt,name=Version,proto3" json:"Version,omitempty"`
	Action               string   `protobuf:"bytes,2,opt,name=Action,proto3" json:"Action,omitempty"`
	ActionValue          string   `protobuf:"bytes,3,opt,name=ActionValue,proto3" json:"ActionValue,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ControlStreamData) Descriptor

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

func (*ControlStreamData) GetAction

func (m *ControlStreamData) GetAction() string

func (*ControlStreamData) GetActionValue

func (m *ControlStreamData) GetActionValue() string

func (*ControlStreamData) GetVersion

func (m *ControlStreamData) GetVersion() int32

func (*ControlStreamData) ProtoMessage

func (*ControlStreamData) ProtoMessage()

func (*ControlStreamData) Reset

func (m *ControlStreamData) Reset()

func (*ControlStreamData) String

func (m *ControlStreamData) String() string

func (*ControlStreamData) XXX_DiscardUnknown

func (m *ControlStreamData) XXX_DiscardUnknown()

func (*ControlStreamData) XXX_Marshal

func (m *ControlStreamData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ControlStreamData) XXX_Merge

func (dst *ControlStreamData) XXX_Merge(src proto.Message)

func (*ControlStreamData) XXX_Size

func (m *ControlStreamData) XXX_Size() int

func (*ControlStreamData) XXX_Unmarshal

func (m *ControlStreamData) XXX_Unmarshal(b []byte) error

type DatatunnelControllerClient

type DatatunnelControllerClient interface {
	ControlStream(ctx context.Context, opts ...grpc.CallOption) (DatatunnelController_ControlStreamClient, error)
}

DatatunnelControllerClient is the client API for DatatunnelController 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 NewDatatunnelControllerClient

func NewDatatunnelControllerClient(cc grpc.ClientConnInterface) DatatunnelControllerClient

type DatatunnelControllerServer

type DatatunnelControllerServer interface {
	ControlStream(DatatunnelController_ControlStreamServer) error
	// contains filtered or unexported methods
}

DatatunnelControllerServer is the server API for DatatunnelController service. All implementations must embed UnimplementedDatatunnelControllerServer for forward compatibility

type DatatunnelController_ControlStreamClient

type DatatunnelController_ControlStreamClient interface {
	Send(*ControlStreamData) error
	Recv() (*ControlStreamData, error)
	grpc.ClientStream
}

type DatatunnelController_ControlStreamServer

type DatatunnelController_ControlStreamServer interface {
	Send(*ControlStreamData) error
	Recv() (*ControlStreamData, error)
	grpc.ServerStream
}

type UnimplementedDatatunnelControllerServer

type UnimplementedDatatunnelControllerServer struct {
}

UnimplementedDatatunnelControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedDatatunnelControllerServer) ControlStream

func (UnimplementedDatatunnelControllerServer) ControlStream(DatatunnelController_ControlStreamServer) error

type UnsafeDatatunnelControllerServer

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

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