util

Documentation

Index

• func CloseChannelsConnection(conn *grpc.ClientConn)
• func CloseMessageStoreConnection(conn *grpc.ClientConn)
• func GetChannelsConnection(c *gin.Context, df DialFactory) *grpc.ClientConn
• func GetMessageStoreConnection(c *gin.Context, df DialFactory) *grpc.ClientConn
• func GetSignature(input, key string) string
• type DialFactory
  • func MakeDialFactory(conf *config.Config) DialFactory
• type DialFactoryImpl
  • func (dfi DialFactoryImpl) GetChannelsAPICon() (*grpc.ClientConn, error)
  • func (dfi DialFactoryImpl) GetMessageStoreCon() (*grpc.ClientConn, error)

Functions

func CloseChannelsConnection

func CloseChannelsConnection(conn *grpc.ClientConn)

func CloseMessageStoreConnection

func CloseMessageStoreConnection(conn *grpc.ClientConn)

func GetChannelsConnection

func GetChannelsConnection(c *gin.Context, df DialFactory) *grpc.ClientConn

func GetMessageStoreConnection

func GetMessageStoreConnection(c *gin.Context, df DialFactory) *grpc.ClientConn

func GetSignature

func GetSignature(input, key string) string

Types

type DialFactory

type DialFactory interface {
	GetMessageStoreCon() (*grpc.ClientConn, error)
	GetChannelsAPICon() (*grpc.ClientConn, error)
}

func MakeDialFactory

func MakeDialFactory(conf *config.Config) DialFactory

type DialFactoryImpl

type DialFactoryImpl struct {
	// contains filtered or unexported fields
}

func (DialFactoryImpl) GetChannelsAPICon

func (dfi DialFactoryImpl) GetChannelsAPICon() (*grpc.ClientConn, error)

func (DialFactoryImpl) GetMessageStoreCon

func (dfi DialFactoryImpl) GetMessageStoreCon() (*grpc.ClientConn, error)