proto

Documentation

Index

• Variables
• func RegisterGRPCConfigOperServer(s *grpc.Server, srv GRPCConfigOperServer)
• type GRPCConfigOperClient
  • func NewGRPCConfigOperClient(cc grpc.ClientConnInterface) GRPCConfigOperClient
• type GRPCConfigOperServer
• type GRPCConfigOper_CreateSubsClient
• type GRPCConfigOper_CreateSubsServer
• type QOSMarking
  • func (*QOSMarking) Descriptor() ([]byte, []int)
  • func (x *QOSMarking) GetMarking() uint32
  • func (*QOSMarking) ProtoMessage()
  • func (x *QOSMarking) ProtoReflect() protoreflect.Message
  • func (x *QOSMarking) Reset()
  • func (x *QOSMarking) String() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (x *SubscribeRequest) GetEncode() int64
  • func (x *SubscribeRequest) GetQos() *QOSMarking
  • func (x *SubscribeRequest) GetRequestId() int64
  • func (x *SubscribeRequest) GetSubcriptionId() string
  • func (x *SubscribeRequest) GetSubscriptions() []string
  • func (*SubscribeRequest) ProtoMessage()
  • func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
  • func (x *SubscribeRequest) Reset()
  • func (x *SubscribeRequest) String() string
• type SubscribeResponse
  • func (*SubscribeResponse) Descriptor() ([]byte, []int)
  • func (x *SubscribeResponse) GetData() []byte
  • func (x *SubscribeResponse) GetErrors() string
  • func (x *SubscribeResponse) GetRequestId() int64
  • func (*SubscribeResponse) ProtoMessage()
  • func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
  • func (x *SubscribeResponse) Reset()
  • func (x *SubscribeResponse) String() string
• type UnimplementedGRPCConfigOperServer
  • func (*UnimplementedGRPCConfigOperServer) CreateSubs(*SubscribeRequest, GRPCConfigOper_CreateSubsServer) error

Variables

var File_mdt_dialin_proto protoreflect.FileDescriptor

Functions

func RegisterGRPCConfigOperServer

func RegisterGRPCConfigOperServer(s *grpc.Server, srv GRPCConfigOperServer)

Types

type GRPCConfigOperClient

type GRPCConfigOperClient interface {
	CreateSubs(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (GRPCConfigOper_CreateSubsClient, error)
}

GRPCConfigOperClient is the client API for GRPCConfigOper service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewGRPCConfigOperClient

func NewGRPCConfigOperClient(cc grpc.ClientConnInterface) GRPCConfigOperClient

type GRPCConfigOperServer

type GRPCConfigOperServer interface {
	CreateSubs(*SubscribeRequest, GRPCConfigOper_CreateSubsServer) error
}

GRPCConfigOperServer is the server API for GRPCConfigOper service.

type GRPCConfigOper_CreateSubsClient

type GRPCConfigOper_CreateSubsClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type GRPCConfigOper_CreateSubsServer

type GRPCConfigOper_CreateSubsServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type QOSMarking

type QOSMarking struct {
	Marking uint32 `protobuf:"varint,1,opt,name=marking,proto3" json:"marking,omitempty"`
	// contains filtered or unexported fields
}

func (*QOSMarking) Descriptor

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

Deprecated: Use QOSMarking.ProtoReflect.Descriptor instead.

func (*QOSMarking) GetMarking

func (x *QOSMarking) GetMarking() uint32

func (*QOSMarking) ProtoMessage

func (*QOSMarking) ProtoMessage()

func (*QOSMarking) ProtoReflect

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

func (*QOSMarking) Reset

func (x *QOSMarking) Reset()

func (*QOSMarking) String

func (x *QOSMarking) String() string

type SubscribeRequest

type SubscribeRequest struct {
	RequestId     int64       `protobuf:"varint,1,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	Encode        int64       `protobuf:"varint,2,opt,name=encode,proto3" json:"encode,omitempty"`
	SubcriptionId string      `protobuf:"bytes,3,opt,name=subcriptionId,proto3" json:"subcriptionId,omitempty"`
	Qos           *QOSMarking `protobuf:"bytes,4,opt,name=qos,proto3" json:"qos,omitempty"`
	Subscriptions []string    `protobuf:"bytes,5,rep,name=Subscriptions,proto3" json:"Subscriptions,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetEncode

func (x *SubscribeRequest) GetEncode() int64

func (*SubscribeRequest) GetQos

func (x *SubscribeRequest) GetQos() *QOSMarking

func (*SubscribeRequest) GetRequestId

func (x *SubscribeRequest) GetRequestId() int64

func (*SubscribeRequest) GetSubcriptionId

func (x *SubscribeRequest) GetSubcriptionId() string

func (*SubscribeRequest) GetSubscriptions

func (x *SubscribeRequest) GetSubscriptions() []string

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect

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

func (*SubscribeRequest) Reset

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String

func (x *SubscribeRequest) String() string

type SubscribeResponse

type SubscribeResponse struct {
	RequestId int64  `protobuf:"varint,1,opt,name=RequestId,proto3" json:"RequestId,omitempty"`
	Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Errors    string `protobuf:"bytes,3,opt,name=errors,proto3" json:"errors,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetData

func (x *SubscribeResponse) GetData() []byte

func (*SubscribeResponse) GetErrors

func (x *SubscribeResponse) GetErrors() string

func (*SubscribeResponse) GetRequestId

func (x *SubscribeResponse) GetRequestId() int64

func (*SubscribeResponse) ProtoMessage

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect

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

func (*SubscribeResponse) Reset

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String

func (x *SubscribeResponse) String() string

type UnimplementedGRPCConfigOperServer

type UnimplementedGRPCConfigOperServer struct {
}

UnimplementedGRPCConfigOperServer can be embedded to have forward compatible implementations.

func (*UnimplementedGRPCConfigOperServer) CreateSubs

func (*UnimplementedGRPCConfigOperServer) CreateSubs(*SubscribeRequest, GRPCConfigOper_CreateSubsServer) error