grpc

Documentation

Index

• func Recv(id uuid.UUID, logger *zap.Logger, stream indexer.IndexerService_TaskRPCClient, ...)
• type AwaitingPing
• type Client
  • func NewClient(maxGrpcReceiveSize, maxGrpcSendSize int) *Client
  • func (c *Client) Run(ctx context.Context, logger *zap.Logger, stream *structs.StreamAccess)
  • func (c *Client) Type() string
• type ConnectGRPCRunner

Functions

func Recv

func Recv(id uuid.UUID, logger *zap.Logger, stream indexer.IndexerService_TaskRPCClient, internalStream *structs.StreamAccess, pingCh chan<- structs.TaskResponse, finishCh chan error)

Recv listener for stream messages

Types

type AwaitingPing

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

AwaitingPing is basic iinformation about sent ping's

type Client

type Client struct {
	GrpcMaxRecvSize int
	GrpcMaxSendSize int
}

Client is GRPC implementation for connectivity

func NewClient

func NewClient(maxGrpcReceiveSize, maxGrpcSendSize int) *Client

NewClient Client constructor

func (*Client) Run

func (c *Client) Run(ctx context.Context, logger *zap.Logger, stream *structs.StreamAccess)

Run runs grpc client, connecting to given address and maintaining connection

func (*Client) Type

func (c *Client) Type() string

Type returns client type

type ConnectGRPCRunner

type ConnectGRPCRunner interface {
	Connect(ctx context.Context, stream *structs.StreamAccess) error
	Run(ctx context.Context, logger *zap.Logger, stream *structs.StreamAccess)
}

ConnectGRPCRunner GRPC Runner interface