Documentation ¶
Index ¶
- type MetaServer
- func (server *MetaServer) AddStreamServer(_ context.Context, request *proto.AddStreamServerRequest) (*proto.AddStreamServerResponse, error)
- func (server *MetaServer) CreateStream(_ context.Context, request *proto.CreateStreamRequest) (*proto.CreateStreamResponse, error)
- func (server *MetaServer) DeleteMQTTClientSession(ctx context.Context, request *proto.DeleteMQTTClientSessionRequest) (*proto.DeleteMQTTClientSessionResponse, error)
- func (server *MetaServer) DeleteStreamServer(_ context.Context, request *proto.DeleteStreamServerRequest) (*empty.Empty, error)
- func (server *MetaServer) GetOrCreateMQTTClientSession(ctx context.Context, request *proto.GetOrCreateMQTTClientSessionRequest) (*proto.GetOrCreateMQTTClientSessionResponse, error)
- func (server *MetaServer) GetOrCreateStream(_ context.Context, request *proto.GetStreamInfoRequest) (*proto.GetStreamInfoResponse, error)
- func (server *MetaServer) GetStreamInfo(_ context.Context, request *proto.GetStreamInfoRequest) (*proto.GetStreamInfoResponse, error)
- func (server *MetaServer) GetStreamReadOffset(_ context.Context, request *proto.GetStreamReadOffsetRequest) (*proto.GetStreamReadOffsetResponse, error)
- func (server *MetaServer) GetStreamServer(_ context.Context, request *proto.GetStreamServerRequest) (*store.StreamServerInfoItem, error)
- func (server *MetaServer) ListStreamServer(_ context.Context, _ *empty.Empty) (*proto.ListStreamServerResponse, error)
- func (server *MetaServer) SetStreamReadOffset(_ context.Context, request *proto.SetStreamReadOffsetRequest) (*empty.Empty, error)
- func (server *MetaServer) Start() error
- func (server *MetaServer) StreamServerHeartbeat(stream proto.MetaService_StreamServerHeartbeatServer) error
- func (server *MetaServer) UpdateMQTTClientSession(ctx context.Context, request *proto.UpdateMQTTClientSessionRequest) (*empty.Empty, error)
- type Options
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MetaServer ¶
type MetaServer struct { Options // contains filtered or unexported fields }
func NewMetaServer ¶
func NewMetaServer(options Options) *MetaServer
func (*MetaServer) AddStreamServer ¶
func (server *MetaServer) AddStreamServer(_ context.Context, request *proto.AddStreamServerRequest) (*proto.AddStreamServerResponse, error)
func (*MetaServer) CreateStream ¶
func (server *MetaServer) CreateStream(_ context.Context, request *proto.CreateStreamRequest) (*proto.CreateStreamResponse, error)
func (*MetaServer) DeleteMQTTClientSession ¶
func (server *MetaServer) DeleteMQTTClientSession(ctx context.Context, request *proto.DeleteMQTTClientSessionRequest) (*proto.DeleteMQTTClientSessionResponse, error)
func (*MetaServer) DeleteStreamServer ¶
func (server *MetaServer) DeleteStreamServer(_ context.Context, request *proto.DeleteStreamServerRequest) (*empty.Empty, error)
func (*MetaServer) GetOrCreateMQTTClientSession ¶
func (server *MetaServer) GetOrCreateMQTTClientSession(ctx context.Context, request *proto.GetOrCreateMQTTClientSessionRequest) (*proto.GetOrCreateMQTTClientSessionResponse, error)
func (*MetaServer) GetOrCreateStream ¶
func (server *MetaServer) GetOrCreateStream(_ context.Context, request *proto.GetStreamInfoRequest) (*proto.GetStreamInfoResponse, error)
func (*MetaServer) GetStreamInfo ¶
func (server *MetaServer) GetStreamInfo(_ context.Context, request *proto.GetStreamInfoRequest) (*proto.GetStreamInfoResponse, error)
func (*MetaServer) GetStreamReadOffset ¶
func (server *MetaServer) GetStreamReadOffset(_ context.Context, request *proto.GetStreamReadOffsetRequest) (*proto.GetStreamReadOffsetResponse, error)
func (*MetaServer) GetStreamServer ¶
func (server *MetaServer) GetStreamServer(_ context.Context, request *proto.GetStreamServerRequest) (*store.StreamServerInfoItem, error)
func (*MetaServer) ListStreamServer ¶
func (server *MetaServer) ListStreamServer(_ context.Context, _ *empty.Empty) (*proto.ListStreamServerResponse, error)
func (*MetaServer) SetStreamReadOffset ¶
func (server *MetaServer) SetStreamReadOffset(_ context.Context, request *proto.SetStreamReadOffsetRequest) (*empty.Empty, error)
func (*MetaServer) Start ¶
func (server *MetaServer) Start() error
func (*MetaServer) StreamServerHeartbeat ¶
func (server *MetaServer) StreamServerHeartbeat(stream proto.MetaService_StreamServerHeartbeatServer) error
func (*MetaServer) UpdateMQTTClientSession ¶
func (server *MetaServer) UpdateMQTTClientSession(ctx context.Context, request *proto.UpdateMQTTClientSessionRequest) (*empty.Empty, error)
type Options ¶
type Options struct { LogFile string `json:"log"` LogLevel logrus.Level `json:"log_level"` GRPCBind int `json:"grpc_bind"` MMdbOptions mmdb.Options `json:"mmdb_options"` }
func DefaultOptions ¶
func DefaultOptions() Options
func (Options) GetMMdbOptions ¶
func (Options) WithGRPCBind ¶
func (Options) WithLogFile ¶
Click to show internal directories.
Click to hide internal directories.