grpcmanagers

Documentation

Index

• Constants
• func AllDialOptions(grpcConfig config.GrpcConfiguration, options ...grpc.DialOption) []grpc.DialOption
• func GrpcChannelOptionsFromGrpcConfig(grpcConfig config.GrpcConfiguration) []grpc.DialOption
• func TransportCredentialsChannelOption() grpc.DialOption
• type AuthGrpcManager
  • func NewAuthGrpcManager(request *models.AuthGrpcManagerRequest) (*AuthGrpcManager, momentoerrors.MomentoSvcErr)
  • func (authManager *AuthGrpcManager) Close() momentoerrors.MomentoSvcErr
• type DataGrpcManager
  • func NewUnaryDataGrpcManager(request *models.DataGrpcManagerRequest) (*DataGrpcManager, momentoerrors.MomentoSvcErr)
  • func (dataManager *DataGrpcManager) Close() momentoerrors.MomentoSvcErr
  • func (gm *DataGrpcManager) Connect(ctx context.Context) error
• type LeaderboardGrpcManager
  • func NewLeaderboardGrpcManager(request *models.LeaderboardGrpcManagerRequest) (*LeaderboardGrpcManager, momentoerrors.MomentoSvcErr)
  • func (grpcManager *LeaderboardGrpcManager) Close() momentoerrors.MomentoSvcErr
• type PingGrpcManager
  • func NewPingGrpcManager(request *models.PingGrpcManagerRequest) (*PingGrpcManager, momentoerrors.MomentoSvcErr)
  • func (pingManager *PingGrpcManager) Close() momentoerrors.MomentoSvcErr
• type ScsControlGrpcManager
  • func NewScsControlGrpcManager(request *models.ControlGrpcManagerRequest) (*ScsControlGrpcManager, momentoerrors.MomentoSvcErr)
  • func (controlManager *ScsControlGrpcManager) Close() momentoerrors.MomentoSvcErr
• type StoreGrpcManager
  • func NewStoreGrpcManager(request *models.StoreGrpcManagerRequest) (*StoreGrpcManager, momentoerrors.MomentoSvcErr)
  • func (grpcManager *StoreGrpcManager) Close() momentoerrors.MomentoSvcErr
• type TokenGrpcManager
  • func NewTokenGrpcManager(request *models.TokenGrpcManagerRequest) (*TokenGrpcManager, momentoerrors.MomentoSvcErr)
  • func (tokenManager *TokenGrpcManager) Close() momentoerrors.MomentoSvcErr
• type TopicGrpcManager
  • func NewStreamTopicGrpcManager(request *models.TopicStreamGrpcManagerRequest) (*TopicGrpcManager, momentoerrors.MomentoSvcErr)
  • func (topicManager *TopicGrpcManager) Close() momentoerrors.MomentoSvcErr

Constants

const AuthPort = ":443"

const CachePort = ":443"

const ControlPort = ":443"

const LeaderboardPort = ":443"

const PingPort = ":443"

const StoragePort = ":443"

const TokenPort = ":443"

Functions

func AllDialOptions

func AllDialOptions(grpcConfig config.GrpcConfiguration, options ...grpc.DialOption) []grpc.DialOption

func GrpcChannelOptionsFromGrpcConfig

func GrpcChannelOptionsFromGrpcConfig(grpcConfig config.GrpcConfiguration) []grpc.DialOption

func TransportCredentialsChannelOption

func TransportCredentialsChannelOption() grpc.DialOption

Types

type AuthGrpcManager

type AuthGrpcManager struct {
	Conn      *grpc.ClientConn
	AuthToken string
}

func NewAuthGrpcManager

func NewAuthGrpcManager(request *models.AuthGrpcManagerRequest) (*AuthGrpcManager, momentoerrors.MomentoSvcErr)

func (*AuthGrpcManager) Close

func (authManager *AuthGrpcManager) Close() momentoerrors.MomentoSvcErr

type DataGrpcManager

type DataGrpcManager struct {
	Conn *grpc.ClientConn
}

func NewUnaryDataGrpcManager

func NewUnaryDataGrpcManager(request *models.DataGrpcManagerRequest) (*DataGrpcManager, momentoerrors.MomentoSvcErr)

func (*DataGrpcManager) Close

func (dataManager *DataGrpcManager) Close() momentoerrors.MomentoSvcErr

func (*DataGrpcManager) Connect

func (gm *DataGrpcManager) Connect(ctx context.Context) error

type LeaderboardGrpcManager

type LeaderboardGrpcManager struct {
	Conn *grpc.ClientConn
}

func NewLeaderboardGrpcManager

func NewLeaderboardGrpcManager(request *models.LeaderboardGrpcManagerRequest) (*LeaderboardGrpcManager, momentoerrors.MomentoSvcErr)

func (*LeaderboardGrpcManager) Close

func (grpcManager *LeaderboardGrpcManager) Close() momentoerrors.MomentoSvcErr

type PingGrpcManager

type PingGrpcManager struct {
	Conn *grpc.ClientConn
}

func NewPingGrpcManager

func NewPingGrpcManager(request *models.PingGrpcManagerRequest) (*PingGrpcManager, momentoerrors.MomentoSvcErr)

func (*PingGrpcManager) Close

func (pingManager *PingGrpcManager) Close() momentoerrors.MomentoSvcErr

type ScsControlGrpcManager

type ScsControlGrpcManager struct {
	Conn *grpc.ClientConn
}

func NewScsControlGrpcManager

func NewScsControlGrpcManager(request *models.ControlGrpcManagerRequest) (*ScsControlGrpcManager, momentoerrors.MomentoSvcErr)

func (*ScsControlGrpcManager) Close

func (controlManager *ScsControlGrpcManager) Close() momentoerrors.MomentoSvcErr

type StoreGrpcManager

type StoreGrpcManager struct {
	Conn *grpc.ClientConn
}

func NewStoreGrpcManager

func NewStoreGrpcManager(request *models.StoreGrpcManagerRequest) (*StoreGrpcManager, momentoerrors.MomentoSvcErr)

func (*StoreGrpcManager) Close

func (grpcManager *StoreGrpcManager) Close() momentoerrors.MomentoSvcErr

type TokenGrpcManager

type TokenGrpcManager struct {
	Conn      *grpc.ClientConn
	AuthToken string
}

func NewTokenGrpcManager

func NewTokenGrpcManager(request *models.TokenGrpcManagerRequest) (*TokenGrpcManager, momentoerrors.MomentoSvcErr)

func (*TokenGrpcManager) Close

func (tokenManager *TokenGrpcManager) Close() momentoerrors.MomentoSvcErr

type TopicGrpcManager

type TopicGrpcManager struct {
	Conn         *grpc.ClientConn
	StreamClient pb.PubsubClient
}

func NewStreamTopicGrpcManager

func NewStreamTopicGrpcManager(request *models.TopicStreamGrpcManagerRequest) (*TopicGrpcManager, momentoerrors.MomentoSvcErr)

func (*TopicGrpcManager) Close

func (topicManager *TopicGrpcManager) Close() momentoerrors.MomentoSvcErr