meta_server

README

meta-server

metadata server.it manager stream-server cluster,stream reader/writer,health status and it is a metadata store

todo

• raft support for replicate

Documentation

Index

• type MetaServer
  • func NewMetaServer(options Options) *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
  • func DefaultOptions() Options
  • func (option Options) GetMMdbOptions() mmdb.Options
  • func (option Options) WithGRPCBind(port int) Options
  • func (option Options) WithLogFile(logFile string) Options
  • func (option Options) WithLogLevel(LogLevel logrus.Level) Options
  • func (option Options) WithMMdbOptions(options mmdb.Options) Options

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 (option Options) GetMMdbOptions() mmdb.Options

func (Options) WithGRPCBind

func (option Options) WithGRPCBind(port int) Options

func (Options) WithLogFile

func (option Options) WithLogFile(logFile string) Options

func (Options) WithLogLevel

func (option Options) WithLogLevel(LogLevel logrus.Level) Options

func (Options) WithMMdbOptions

func (option Options) WithMMdbOptions(options mmdb.Options) Options