grpc_client

Documentation

Index

• type Clients
  • func InitClients(conn *grpc.ClientConn) *Clients
• type DialFactory
  • func NewDialFactory(conf *config.GrpcClientConfig) DialFactory
• type DialFactoryImpl
  • func (dfi DialFactoryImpl) Close(conn *grpc.ClientConn)
  • func (dfi DialFactoryImpl) GetEventsProcessingPlatformConn() (*grpc.ClientConn, error)

Types

type Clients

type Clients struct {
	InvoiceClient      invoice_grpc_service.InvoiceGrpcServiceClient
	OrganizationClient organization_grpc_service.OrganizationGrpcServiceClient
	EventStoreClient   eventstorepb.EventStoreGrpcServiceClient
}

func InitClients

func InitClients(conn *grpc.ClientConn) *Clients

type DialFactory

type DialFactory interface {
	GetEventsProcessingPlatformConn() (*grpc.ClientConn, error)
	Close(conn *grpc.ClientConn)
}

func NewDialFactory

func NewDialFactory(conf *config.GrpcClientConfig) DialFactory

type DialFactoryImpl

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

func (DialFactoryImpl) Close

func (dfi DialFactoryImpl) Close(conn *grpc.ClientConn)

func (DialFactoryImpl) GetEventsProcessingPlatformConn

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