grpcapi

Documentation

Index

• type GrpcApi
  • func NewGrpcApi(params Params) GrpcApi
  • func (api GrpcApi) BatchSubmitBalanceChanges(ctx context.Context, in *apipb.BatchSubmitBalanceChangesRequest) (*apipb.BatchSubmitBalanceChangesResponse, error)
• type Params

Types

type GrpcApi

type GrpcApi struct {
	apipb.UnimplementedAccountBalanceServiceServer
	// contains filtered or unexported fields
}

func NewGrpcApi

func NewGrpcApi(params Params) GrpcApi

func (GrpcApi) BatchSubmitBalanceChanges

func (api GrpcApi) BatchSubmitBalanceChanges(ctx context.Context, in *apipb.BatchSubmitBalanceChangesRequest) (*apipb.BatchSubmitBalanceChangesResponse, error)

type Params

type Params struct {
	DBRepo     domain.DBRepository
	RedisRepo  domain.RedisRepository
	Producer   mq.Producer
	WorkerPool utils.WorkerPool
	fx.In
}