bchd

Documentation

Index

• func NewReqContext() context.Context
• type GRPCClient
  • func NewGrpcClient(logger log.Logger, monitor *monitoring.HttpMonitoring, ...) (grpcClient *GRPCClient, err error)
  • func (gc *GRPCClient) Close() error
  • func (gc *GRPCClient) ReadTransactionStream(reqCtx context.Context, cancel context.CancelFunc, ...) error

Functions

func NewReqContext

func NewReqContext() context.Context

Types

type GRPCClient

type GRPCClient struct {
	Client pb.BchrpcClient
	// contains filtered or unexported fields
}

func NewGrpcClient

func NewGrpcClient(logger log.Logger, monitor *monitoring.HttpMonitoring, counter *txcounter.TxCounter) (grpcClient *GRPCClient, err error)

func (*GRPCClient) Close

func (gc *GRPCClient) Close() error

func (*GRPCClient) ReadTransactionStream

func (gc *GRPCClient) ReadTransactionStream(reqCtx context.Context, cancel context.CancelFunc, msgBuilder *social.MessageBuilder) error