proto

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 7, 2020 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_streamIO_proto_meta_proto protoreflect.FileDescriptor
View Source 
var File_streamIO_proto_stream_proto protoreflect.FileDescriptor

Functions

func RegisterMetaServiceServer 

func RegisterMetaServiceServer(s *grpc.Server, srv MetaServiceServer)

func RegisterStreamServiceServer 

func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer)

Types

type AddStreamServerRequest 

type AddStreamServerRequest struct {
	StreamServerInfoItem *store.StreamServerInfoItem `protobuf:"bytes,1,opt,name=stream_server_info_item,json=streamServerInfoItem,proto3" json:"stream_server_info_item,omitempty"`
	// contains filtered or unexported fields
}

func (*AddStreamServerRequest) Descriptor deprecated 

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

Deprecated: Use AddStreamServerRequest.ProtoReflect.Descriptor instead.

func (*AddStreamServerRequest) GetStreamServerInfoItem 

func (x *AddStreamServerRequest) GetStreamServerInfoItem() *store.StreamServerInfoItem

func (*AddStreamServerRequest) ProtoMessage 

func (*AddStreamServerRequest) ProtoMessage()

func (*AddStreamServerRequest) ProtoReflect 

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

func (*AddStreamServerRequest) Reset 

func (x *AddStreamServerRequest) Reset()

func (*AddStreamServerRequest) String 

func (x *AddStreamServerRequest) String() string

type AddStreamServerResponse 

type AddStreamServerResponse struct {
	StreamServerInfoItem *store.StreamServerInfoItem `protobuf:"bytes,1,opt,name=stream_server_info_item,json=streamServerInfoItem,proto3" json:"stream_server_info_item,omitempty"`
	// contains filtered or unexported fields
}

func (*AddStreamServerResponse) Descriptor deprecated 

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

Deprecated: Use AddStreamServerResponse.ProtoReflect.Descriptor instead.

func (*AddStreamServerResponse) GetStreamServerInfoItem 

func (x *AddStreamServerResponse) GetStreamServerInfoItem() *store.StreamServerInfoItem

func (*AddStreamServerResponse) ProtoMessage 

func (*AddStreamServerResponse) ProtoMessage()

func (*AddStreamServerResponse) ProtoReflect 

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

func (*AddStreamServerResponse) Reset 

func (x *AddStreamServerResponse) Reset()

func (*AddStreamServerResponse) String 

func (x *AddStreamServerResponse) String() string

type CreateStreamRequest 

type CreateStreamRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamRequest) Descriptor deprecated 

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

Deprecated: Use CreateStreamRequest.ProtoReflect.Descriptor instead.

func (*CreateStreamRequest) GetName 

func (x *CreateStreamRequest) GetName() string

func (*CreateStreamRequest) ProtoMessage 

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) ProtoReflect 

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

func (*CreateStreamRequest) Reset 

func (x *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String 

func (x *CreateStreamRequest) String() string

type CreateStreamResponse 

type CreateStreamResponse struct {
	Info *store.StreamInfoItem `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateStreamResponse) Descriptor deprecated 

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

Deprecated: Use CreateStreamResponse.ProtoReflect.Descriptor instead.

func (*CreateStreamResponse) GetInfo 

func (x *CreateStreamResponse) GetInfo() *store.StreamInfoItem

func (*CreateStreamResponse) ProtoMessage 

func (*CreateStreamResponse) ProtoMessage()

func (*CreateStreamResponse) ProtoReflect 

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

func (*CreateStreamResponse) Reset 

func (x *CreateStreamResponse) Reset()

func (*CreateStreamResponse) String 

func (x *CreateStreamResponse) String() string

type DeleteMQTTClientSessionRequest 

type DeleteMQTTClientSessionRequest struct {
	ClientIdentifier string `protobuf:"bytes,1,opt,name=client_identifier,json=clientIdentifier,proto3" json:"client_identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMQTTClientSessionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteMQTTClientSessionRequest.ProtoReflect.Descriptor instead.

func (*DeleteMQTTClientSessionRequest) GetClientIdentifier 

func (x *DeleteMQTTClientSessionRequest) GetClientIdentifier() string

func (*DeleteMQTTClientSessionRequest) ProtoMessage 

func (*DeleteMQTTClientSessionRequest) ProtoMessage()

func (*DeleteMQTTClientSessionRequest) ProtoReflect 

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

func (*DeleteMQTTClientSessionRequest) Reset 

func (x *DeleteMQTTClientSessionRequest) Reset()

func (*DeleteMQTTClientSessionRequest) String 

func (x *DeleteMQTTClientSessionRequest) String() string

type DeleteMQTTClientSessionResponse 

type DeleteMQTTClientSessionResponse struct {
	SessionItem *store.MQTTSessionItem `protobuf:"bytes,1,opt,name=sessionItem,proto3" json:"sessionItem,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteMQTTClientSessionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteMQTTClientSessionResponse.ProtoReflect.Descriptor instead.

func (*DeleteMQTTClientSessionResponse) GetSessionItem 

func (x *DeleteMQTTClientSessionResponse) GetSessionItem() *store.MQTTSessionItem

func (*DeleteMQTTClientSessionResponse) ProtoMessage 

func (*DeleteMQTTClientSessionResponse) ProtoMessage()

func (*DeleteMQTTClientSessionResponse) ProtoReflect 

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

func (*DeleteMQTTClientSessionResponse) Reset 

func (x *DeleteMQTTClientSessionResponse) Reset()

func (*DeleteMQTTClientSessionResponse) String 

func (x *DeleteMQTTClientSessionResponse) String() string

type DeleteStreamServerRequest 

type DeleteStreamServerRequest struct {
	StreamServerInfoItem *store.StreamServerInfoItem `protobuf:"bytes,1,opt,name=stream_server_info_item,json=streamServerInfoItem,proto3" json:"stream_server_info_item,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteStreamServerRequest) Descriptor deprecated 

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

Deprecated: Use DeleteStreamServerRequest.ProtoReflect.Descriptor instead.

func (*DeleteStreamServerRequest) GetStreamServerInfoItem 

func (x *DeleteStreamServerRequest) GetStreamServerInfoItem() *store.StreamServerInfoItem

func (*DeleteStreamServerRequest) ProtoMessage 

func (*DeleteStreamServerRequest) ProtoMessage()

func (*DeleteStreamServerRequest) ProtoReflect 

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

func (*DeleteStreamServerRequest) Reset 

func (x *DeleteStreamServerRequest) Reset()

func (*DeleteStreamServerRequest) String 

func (x *DeleteStreamServerRequest) String() string

type GetOrCreateMQTTClientSessionRequest 

type GetOrCreateMQTTClientSessionRequest struct {
	ClientIdentifier string `protobuf:"bytes,2,opt,name=client_identifier,json=clientIdentifier,proto3" json:"client_identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateMQTTClientSessionRequest) Descriptor deprecated 

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

Deprecated: Use GetOrCreateMQTTClientSessionRequest.ProtoReflect.Descriptor instead.

func (*GetOrCreateMQTTClientSessionRequest) GetClientIdentifier 

func (x *GetOrCreateMQTTClientSessionRequest) GetClientIdentifier() string

func (*GetOrCreateMQTTClientSessionRequest) ProtoMessage 

func (*GetOrCreateMQTTClientSessionRequest) ProtoMessage()

func (*GetOrCreateMQTTClientSessionRequest) ProtoReflect 

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

func (*GetOrCreateMQTTClientSessionRequest) Reset 

func (x *GetOrCreateMQTTClientSessionRequest) Reset()

func (*GetOrCreateMQTTClientSessionRequest) String 

func (x *GetOrCreateMQTTClientSessionRequest) String() string

type GetOrCreateMQTTClientSessionResponse 

type GetOrCreateMQTTClientSessionResponse struct {
	SessionItem *store.MQTTSessionItem `protobuf:"bytes,1,opt,name=sessionItem,proto3" json:"sessionItem,omitempty"`
	Create      bool                   `protobuf:"varint,2,opt,name=Create,proto3" json:"Create,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOrCreateMQTTClientSessionResponse) Descriptor deprecated 

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

Deprecated: Use GetOrCreateMQTTClientSessionResponse.ProtoReflect.Descriptor instead.

func (*GetOrCreateMQTTClientSessionResponse) GetCreate 

func (x *GetOrCreateMQTTClientSessionResponse) GetCreate() bool

func (*GetOrCreateMQTTClientSessionResponse) GetSessionItem 

func (x *GetOrCreateMQTTClientSessionResponse) GetSessionItem() *store.MQTTSessionItem

func (*GetOrCreateMQTTClientSessionResponse) ProtoMessage 

func (*GetOrCreateMQTTClientSessionResponse) ProtoMessage()

func (*GetOrCreateMQTTClientSessionResponse) ProtoReflect 

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

func (*GetOrCreateMQTTClientSessionResponse) Reset 

func (x *GetOrCreateMQTTClientSessionResponse) Reset()

func (*GetOrCreateMQTTClientSessionResponse) String 

func (x *GetOrCreateMQTTClientSessionResponse) String() string

type GetStreamInfoRequest 

type GetStreamInfoRequest struct {
	Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamInfoRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamInfoRequest.ProtoReflect.Descriptor instead.

func (*GetStreamInfoRequest) GetName 

func (x *GetStreamInfoRequest) GetName() string

func (*GetStreamInfoRequest) ProtoMessage 

func (*GetStreamInfoRequest) ProtoMessage()

func (*GetStreamInfoRequest) ProtoReflect 

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

func (*GetStreamInfoRequest) Reset 

func (x *GetStreamInfoRequest) Reset()

func (*GetStreamInfoRequest) String 

func (x *GetStreamInfoRequest) String() string

type GetStreamInfoResponse 

type GetStreamInfoResponse struct {
	Info   *store.StreamInfoItem `protobuf:"bytes,1,opt,name=Info,proto3" json:"Info,omitempty"`
	Create bool                  `protobuf:"varint,2,opt,name=create,proto3" json:"create,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamInfoResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamInfoResponse.ProtoReflect.Descriptor instead.

func (*GetStreamInfoResponse) GetCreate 

func (x *GetStreamInfoResponse) GetCreate() bool

func (*GetStreamInfoResponse) GetInfo 

func (x *GetStreamInfoResponse) GetInfo() *store.StreamInfoItem

func (*GetStreamInfoResponse) ProtoMessage 

func (*GetStreamInfoResponse) ProtoMessage()

func (*GetStreamInfoResponse) ProtoReflect 

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

func (*GetStreamInfoResponse) Reset 

func (x *GetStreamInfoResponse) Reset()

func (*GetStreamInfoResponse) String 

func (x *GetStreamInfoResponse) String() string

type GetStreamReadOffsetRequest 

type GetStreamReadOffsetRequest struct {
	SessionId int64 `protobuf:"varint,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	StreamId  int64 `protobuf:"varint,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamReadOffsetRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamReadOffsetRequest.ProtoReflect.Descriptor instead.

func (*GetStreamReadOffsetRequest) GetSessionId 

func (x *GetStreamReadOffsetRequest) GetSessionId() int64

func (*GetStreamReadOffsetRequest) GetStreamId 

func (x *GetStreamReadOffsetRequest) GetStreamId() int64

func (*GetStreamReadOffsetRequest) ProtoMessage 

func (*GetStreamReadOffsetRequest) ProtoMessage()

func (*GetStreamReadOffsetRequest) ProtoReflect 

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

func (*GetStreamReadOffsetRequest) Reset 

func (x *GetStreamReadOffsetRequest) Reset()

func (*GetStreamReadOffsetRequest) String 

func (x *GetStreamReadOffsetRequest) String() string

type GetStreamReadOffsetResponse 

type GetStreamReadOffsetResponse struct {
	SSOffset *store.SSOffsetItem `protobuf:"bytes,1,opt,name=SSOffset,proto3" json:"SSOffset,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamReadOffsetResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamReadOffsetResponse.ProtoReflect.Descriptor instead.

func (*GetStreamReadOffsetResponse) GetSSOffset 

func (x *GetStreamReadOffsetResponse) GetSSOffset() *store.SSOffsetItem

func (*GetStreamReadOffsetResponse) ProtoMessage 

func (*GetStreamReadOffsetResponse) ProtoMessage()

func (*GetStreamReadOffsetResponse) ProtoReflect 

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

func (*GetStreamReadOffsetResponse) Reset 

func (x *GetStreamReadOffsetResponse) Reset()

func (*GetStreamReadOffsetResponse) String 

func (x *GetStreamReadOffsetResponse) String() string

type GetStreamServerRequest 

type GetStreamServerRequest struct {
	StreamServerID int64 `protobuf:"varint,1,opt,name=streamServerID,proto3" json:"streamServerID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamServerRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamServerRequest.ProtoReflect.Descriptor instead.

func (*GetStreamServerRequest) GetStreamServerID 

func (x *GetStreamServerRequest) GetStreamServerID() int64

func (*GetStreamServerRequest) ProtoMessage 

func (*GetStreamServerRequest) ProtoMessage()

func (*GetStreamServerRequest) ProtoReflect 

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

func (*GetStreamServerRequest) Reset 

func (x *GetStreamServerRequest) Reset()

func (*GetStreamServerRequest) String 

func (x *GetStreamServerRequest) String() string

type GetStreamStatRequest 

type GetStreamStatRequest struct {
	StreamID int64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamStatRequest) Descriptor deprecated 

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

Deprecated: Use GetStreamStatRequest.ProtoReflect.Descriptor instead.

func (*GetStreamStatRequest) GetStreamID 

func (x *GetStreamStatRequest) GetStreamID() int64

func (*GetStreamStatRequest) ProtoMessage 

func (*GetStreamStatRequest) ProtoMessage()

func (*GetStreamStatRequest) ProtoReflect 

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

func (*GetStreamStatRequest) Reset 

func (x *GetStreamStatRequest) Reset()

func (*GetStreamStatRequest) String 

func (x *GetStreamStatRequest) String() string

type GetStreamStatResponse 

type GetStreamStatResponse struct {
	StreamID int64 `protobuf:"varint,1,opt,name=streamID,proto3" json:"streamID,omitempty"`
	Begin    int64 `protobuf:"varint,2,opt,name=begin,proto3" json:"begin,omitempty"`
	End      int64 `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStreamStatResponse) Descriptor deprecated 

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

Deprecated: Use GetStreamStatResponse.ProtoReflect.Descriptor instead.

func (*GetStreamStatResponse) GetBegin 

func (x *GetStreamStatResponse) GetBegin() int64

func (*GetStreamStatResponse) GetEnd 

func (x *GetStreamStatResponse) GetEnd() int64

func (*GetStreamStatResponse) GetStreamID 

func (x *GetStreamStatResponse) GetStreamID() int64

func (*GetStreamStatResponse) ProtoMessage 

func (*GetStreamStatResponse) ProtoMessage()

func (*GetStreamStatResponse) ProtoReflect 

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

func (*GetStreamStatResponse) Reset 

func (x *GetStreamStatResponse) Reset()

func (*GetStreamStatResponse) String 

func (x *GetStreamStatResponse) String() string

type ListStreamServerResponse 

type ListStreamServerResponse struct {
	Items []*store.StreamServerInfoItem `protobuf:"bytes,1,rep,name=Items,proto3" json:"Items,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStreamServerResponse) Descriptor deprecated 

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

Deprecated: Use ListStreamServerResponse.ProtoReflect.Descriptor instead.

func (*ListStreamServerResponse) GetItems 

func (x *ListStreamServerResponse) GetItems() []*store.StreamServerInfoItem

func (*ListStreamServerResponse) ProtoMessage 

func (*ListStreamServerResponse) ProtoMessage()

func (*ListStreamServerResponse) ProtoReflect 

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

func (*ListStreamServerResponse) Reset 

func (x *ListStreamServerResponse) Reset()

func (*ListStreamServerResponse) String 

func (x *ListStreamServerResponse) String() string

type MetaServiceClient 

type MetaServiceClient interface {
	AddStreamServer(ctx context.Context, in *AddStreamServerRequest, opts ...grpc.CallOption) (*AddStreamServerResponse, error)
	ListStreamServer(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ListStreamServerResponse, error)
	GetStreamServer(ctx context.Context, in *GetStreamServerRequest, opts ...grpc.CallOption) (*store.StreamServerInfoItem, error)
	DeleteStreamServer(ctx context.Context, in *DeleteStreamServerRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	StreamServerHeartbeat(ctx context.Context, opts ...grpc.CallOption) (MetaService_StreamServerHeartbeatClient, error)
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*CreateStreamResponse, error)
	GetOrCreateStream(ctx context.Context, in *GetStreamInfoRequest, opts ...grpc.CallOption) (*GetStreamInfoResponse, error)
	GetStreamInfo(ctx context.Context, in *GetStreamInfoRequest, opts ...grpc.CallOption) (*GetStreamInfoResponse, error)
	SetStreamReadOffset(ctx context.Context, in *SetStreamReadOffsetRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	GetStreamReadOffset(ctx context.Context, in *GetStreamReadOffsetRequest, opts ...grpc.CallOption) (*GetStreamReadOffsetResponse, error)
	//mqtt
	GetOrCreateMQTTClientSession(ctx context.Context, in *GetOrCreateMQTTClientSessionRequest, opts ...grpc.CallOption) (*GetOrCreateMQTTClientSessionResponse, error)
	DeleteMQTTClientSession(ctx context.Context, in *DeleteMQTTClientSessionRequest, opts ...grpc.CallOption) (*DeleteMQTTClientSessionResponse, error)
	UpdateMQTTClientSession(ctx context.Context, in *UpdateMQTTClientSessionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

MetaServiceClient is the client API for MetaService service.

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

func NewMetaServiceClient 

func NewMetaServiceClient(cc grpc.ClientConnInterface) MetaServiceClient

type MetaServiceServer 

type MetaServiceServer interface {
	AddStreamServer(context.Context, *AddStreamServerRequest) (*AddStreamServerResponse, error)
	ListStreamServer(context.Context, *empty.Empty) (*ListStreamServerResponse, error)
	GetStreamServer(context.Context, *GetStreamServerRequest) (*store.StreamServerInfoItem, error)
	DeleteStreamServer(context.Context, *DeleteStreamServerRequest) (*empty.Empty, error)
	StreamServerHeartbeat(MetaService_StreamServerHeartbeatServer) error
	CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)
	GetOrCreateStream(context.Context, *GetStreamInfoRequest) (*GetStreamInfoResponse, error)
	GetStreamInfo(context.Context, *GetStreamInfoRequest) (*GetStreamInfoResponse, error)
	SetStreamReadOffset(context.Context, *SetStreamReadOffsetRequest) (*empty.Empty, error)
	GetStreamReadOffset(context.Context, *GetStreamReadOffsetRequest) (*GetStreamReadOffsetResponse, error)
	//mqtt
	GetOrCreateMQTTClientSession(context.Context, *GetOrCreateMQTTClientSessionRequest) (*GetOrCreateMQTTClientSessionResponse, error)
	DeleteMQTTClientSession(context.Context, *DeleteMQTTClientSessionRequest) (*DeleteMQTTClientSessionResponse, error)
	UpdateMQTTClientSession(context.Context, *UpdateMQTTClientSessionRequest) (*empty.Empty, error)
}

MetaServiceServer is the server API for MetaService service.

type MetaService_StreamServerHeartbeatClient 

type MetaService_StreamServerHeartbeatClient interface {
	Send(*store.StreamServerHeartbeatItem) error
	Recv() (*empty.Empty, error)
	grpc.ClientStream
}

type MetaService_StreamServerHeartbeatServer 

type MetaService_StreamServerHeartbeatServer interface {
	Send(*empty.Empty) error
	Recv() (*store.StreamServerHeartbeatItem, error)
	grpc.ServerStream
}

type ReadStreamRequest 

type ReadStreamRequest struct {
	StreamId int64 `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Offset   int64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Size     int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	//add watcher to stream-server when stream no exist
	Watch bool `protobuf:"varint,5,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStreamRequest) Descriptor deprecated 

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

Deprecated: Use ReadStreamRequest.ProtoReflect.Descriptor instead.

func (*ReadStreamRequest) GetOffset 

func (x *ReadStreamRequest) GetOffset() int64

func (*ReadStreamRequest) GetSize 

func (x *ReadStreamRequest) GetSize() int64

func (*ReadStreamRequest) GetStreamId 

func (x *ReadStreamRequest) GetStreamId() int64

func (*ReadStreamRequest) GetWatch 

func (x *ReadStreamRequest) GetWatch() bool

func (*ReadStreamRequest) ProtoMessage 

func (*ReadStreamRequest) ProtoMessage()

func (*ReadStreamRequest) ProtoReflect 

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

func (*ReadStreamRequest) Reset 

func (x *ReadStreamRequest) Reset()

func (*ReadStreamRequest) String 

func (x *ReadStreamRequest) String() string

type ReadStreamResponse 

type ReadStreamResponse struct {
	Offset int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Data   []byte `protobuf:"bytes,4,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadStreamResponse) Descriptor deprecated 

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

Deprecated: Use ReadStreamResponse.ProtoReflect.Descriptor instead.

func (*ReadStreamResponse) GetData 

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

func (*ReadStreamResponse) GetOffset 

func (x *ReadStreamResponse) GetOffset() int64

func (*ReadStreamResponse) ProtoMessage 

func (*ReadStreamResponse) ProtoMessage()

func (*ReadStreamResponse) ProtoReflect 

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

func (*ReadStreamResponse) Reset 

func (x *ReadStreamResponse) Reset()

func (*ReadStreamResponse) String 

func (x *ReadStreamResponse) String() string

type SetStreamReadOffsetRequest 

type SetStreamReadOffsetRequest struct {
	SSOffsets []*store.SSOffsetItem `protobuf:"bytes,1,rep,name=SSOffsets,proto3" json:"SSOffsets,omitempty"`
	// contains filtered or unexported fields
}

func (*SetStreamReadOffsetRequest) Descriptor deprecated 

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

Deprecated: Use SetStreamReadOffsetRequest.ProtoReflect.Descriptor instead.

func (*SetStreamReadOffsetRequest) GetSSOffsets 

func (x *SetStreamReadOffsetRequest) GetSSOffsets() []*store.SSOffsetItem

func (*SetStreamReadOffsetRequest) ProtoMessage 

func (*SetStreamReadOffsetRequest) ProtoMessage()

func (*SetStreamReadOffsetRequest) ProtoReflect 

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

func (*SetStreamReadOffsetRequest) Reset 

func (x *SetStreamReadOffsetRequest) Reset()

func (*SetStreamReadOffsetRequest) String 

func (x *SetStreamReadOffsetRequest) String() string

type StreamServiceClient 

type StreamServiceClient interface {
	WriteStream(ctx context.Context, opts ...grpc.CallOption) (StreamService_WriteStreamClient, error)
	ReadStream(ctx context.Context, in *ReadStreamRequest, opts ...grpc.CallOption) (StreamService_ReadStreamClient, error)
	GetStreamStat(ctx context.Context, in *GetStreamStatRequest, opts ...grpc.CallOption) (*GetStreamStatResponse, error)
}

StreamServiceClient is the client API for StreamService service.

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

func NewStreamServiceClient 

func NewStreamServiceClient(cc grpc.ClientConnInterface) StreamServiceClient

type StreamServiceServer 

type StreamServiceServer interface {
	WriteStream(StreamService_WriteStreamServer) error
	ReadStream(*ReadStreamRequest, StreamService_ReadStreamServer) error
	GetStreamStat(context.Context, *GetStreamStatRequest) (*GetStreamStatResponse, error)
}

StreamServiceServer is the server API for StreamService service.

type StreamService_ReadStreamClient 

type StreamService_ReadStreamClient interface {
	Recv() (*ReadStreamResponse, error)
	grpc.ClientStream
}

type StreamService_ReadStreamServer 

type StreamService_ReadStreamServer interface {
	Send(*ReadStreamResponse) error
	grpc.ServerStream
}

type StreamService_WriteStreamClient 

type StreamService_WriteStreamClient interface {
	Send(*WriteStreamRequest) error
	Recv() (*WriteStreamResponse, error)
	grpc.ClientStream
}

type StreamService_WriteStreamServer 

type StreamService_WriteStreamServer interface {
	Send(*WriteStreamResponse) error
	Recv() (*WriteStreamRequest, error)
	grpc.ServerStream
}

type UnimplementedMetaServiceServer 

type UnimplementedMetaServiceServer struct {
}

UnimplementedMetaServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetaServiceServer) AddStreamServer 

func (*UnimplementedMetaServiceServer) AddStreamServer(context.Context, *AddStreamServerRequest) (*AddStreamServerResponse, error)

func (*UnimplementedMetaServiceServer) CreateStream 

func (*UnimplementedMetaServiceServer) CreateStream(context.Context, *CreateStreamRequest) (*CreateStreamResponse, error)

func (*UnimplementedMetaServiceServer) DeleteMQTTClientSession 

func (*UnimplementedMetaServiceServer) DeleteMQTTClientSession(context.Context, *DeleteMQTTClientSessionRequest) (*DeleteMQTTClientSessionResponse, error)

func (*UnimplementedMetaServiceServer) DeleteStreamServer 

func (*UnimplementedMetaServiceServer) DeleteStreamServer(context.Context, *DeleteStreamServerRequest) (*empty.Empty, error)

func (*UnimplementedMetaServiceServer) GetOrCreateMQTTClientSession 

func (*UnimplementedMetaServiceServer) GetOrCreateMQTTClientSession(context.Context, *GetOrCreateMQTTClientSessionRequest) (*GetOrCreateMQTTClientSessionResponse, error)

func (*UnimplementedMetaServiceServer) GetOrCreateStream 

func (*UnimplementedMetaServiceServer) GetOrCreateStream(context.Context, *GetStreamInfoRequest) (*GetStreamInfoResponse, error)

func (*UnimplementedMetaServiceServer) GetStreamInfo 

func (*UnimplementedMetaServiceServer) GetStreamInfo(context.Context, *GetStreamInfoRequest) (*GetStreamInfoResponse, error)

func (*UnimplementedMetaServiceServer) GetStreamReadOffset 

func (*UnimplementedMetaServiceServer) GetStreamReadOffset(context.Context, *GetStreamReadOffsetRequest) (*GetStreamReadOffsetResponse, error)

func (*UnimplementedMetaServiceServer) GetStreamServer 

func (*UnimplementedMetaServiceServer) GetStreamServer(context.Context, *GetStreamServerRequest) (*store.StreamServerInfoItem, error)

func (*UnimplementedMetaServiceServer) ListStreamServer 

func (*UnimplementedMetaServiceServer) ListStreamServer(context.Context, *empty.Empty) (*ListStreamServerResponse, error)

func (*UnimplementedMetaServiceServer) SetStreamReadOffset 

func (*UnimplementedMetaServiceServer) SetStreamReadOffset(context.Context, *SetStreamReadOffsetRequest) (*empty.Empty, error)

func (*UnimplementedMetaServiceServer) StreamServerHeartbeat 

func (*UnimplementedMetaServiceServer) StreamServerHeartbeat(MetaService_StreamServerHeartbeatServer) error

func (*UnimplementedMetaServiceServer) UpdateMQTTClientSession 

func (*UnimplementedMetaServiceServer) UpdateMQTTClientSession(context.Context, *UpdateMQTTClientSessionRequest) (*empty.Empty, error)

type UnimplementedStreamServiceServer 

type UnimplementedStreamServiceServer struct {
}

UnimplementedStreamServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedStreamServiceServer) GetStreamStat 

func (*UnimplementedStreamServiceServer) GetStreamStat(context.Context, *GetStreamStatRequest) (*GetStreamStatResponse, error)

func (*UnimplementedStreamServiceServer) ReadStream 

func (*UnimplementedStreamServiceServer) ReadStream(*ReadStreamRequest, StreamService_ReadStreamServer) error

func (*UnimplementedStreamServiceServer) WriteStream 

func (*UnimplementedStreamServiceServer) WriteStream(StreamService_WriteStreamServer) error

type UpdateMQTTClientSessionRequest 

type UpdateMQTTClientSessionRequest struct {
	ClientIdentifier string           `protobuf:"bytes,1,opt,name=client_identifier,json=clientIdentifier,proto3" json:"client_identifier,omitempty"`
	Subscribe        map[string]int32 `` /* 160-byte string literal not displayed */
	UnSubscribe      []string         `protobuf:"bytes,3,rep,name=unSubscribe,proto3" json:"unSubscribe,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateMQTTClientSessionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateMQTTClientSessionRequest.ProtoReflect.Descriptor instead.

func (*UpdateMQTTClientSessionRequest) GetClientIdentifier 

func (x *UpdateMQTTClientSessionRequest) GetClientIdentifier() string

func (*UpdateMQTTClientSessionRequest) GetSubscribe 

func (x *UpdateMQTTClientSessionRequest) GetSubscribe() map[string]int32

func (*UpdateMQTTClientSessionRequest) GetUnSubscribe 

func (x *UpdateMQTTClientSessionRequest) GetUnSubscribe() []string

func (*UpdateMQTTClientSessionRequest) ProtoMessage 

func (*UpdateMQTTClientSessionRequest) ProtoMessage()

func (*UpdateMQTTClientSessionRequest) ProtoReflect 

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

func (*UpdateMQTTClientSessionRequest) Reset 

func (x *UpdateMQTTClientSessionRequest) Reset()

func (*UpdateMQTTClientSessionRequest) String 

func (x *UpdateMQTTClientSessionRequest) String() string

type WriteStreamRequest 

type WriteStreamRequest struct {
	StreamId  int64  `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Offset    int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Data      []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	RequestId int64  `protobuf:"varint,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteStreamRequest) Descriptor deprecated 

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

Deprecated: Use WriteStreamRequest.ProtoReflect.Descriptor instead.

func (*WriteStreamRequest) GetData 

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

func (*WriteStreamRequest) GetOffset 

func (x *WriteStreamRequest) GetOffset() int64

func (*WriteStreamRequest) GetRequestId 

func (x *WriteStreamRequest) GetRequestId() int64

func (*WriteStreamRequest) GetStreamId 

func (x *WriteStreamRequest) GetStreamId() int64

func (*WriteStreamRequest) ProtoMessage 

func (*WriteStreamRequest) ProtoMessage()

func (*WriteStreamRequest) ProtoReflect 

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

func (*WriteStreamRequest) Reset 

func (x *WriteStreamRequest) Reset()

func (*WriteStreamRequest) String 

func (x *WriteStreamRequest) String() string

type WriteStreamResponse 

type WriteStreamResponse struct {
	StreamId  int64  `protobuf:"varint,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Offset    int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	RequestId int64  `protobuf:"varint,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Err       string `protobuf:"bytes,4,opt,name=err,proto3" json:"err,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteStreamResponse) Descriptor deprecated 

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

Deprecated: Use WriteStreamResponse.ProtoReflect.Descriptor instead.

func (*WriteStreamResponse) GetErr 

func (x *WriteStreamResponse) GetErr() string

func (*WriteStreamResponse) GetOffset 

func (x *WriteStreamResponse) GetOffset() int64

func (*WriteStreamResponse) GetRequestId 

func (x *WriteStreamResponse) GetRequestId() int64

func (*WriteStreamResponse) GetStreamId 

func (x *WriteStreamResponse) GetStreamId() int64

func (*WriteStreamResponse) ProtoMessage 

func (*WriteStreamResponse) ProtoMessage()

func (*WriteStreamResponse) ProtoReflect 

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

func (*WriteStreamResponse) Reset 

func (x *WriteStreamResponse) Reset()

func (*WriteStreamResponse) String 

func (x *WriteStreamResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.