client

Documentation

Index

• type GoFlowGRPCClient
  • func NewGoFlowClient(connString string, opt ...GoFlowGRPCClientOption) (*GoFlowGRPCClient, error)
  • func (g *GoFlowGRPCClient) Get(taskID string) (string, error)
  • func (g *GoFlowGRPCClient) Push(taskType, payload string) (string, error)
• type GoFlowGRPCClientOption
  • func WithLogger(logger log.Logger) GoFlowGRPCClientOption
  • func WithRequestTimeout(requestTimeout time.Duration) GoFlowGRPCClientOption

Types

type GoFlowGRPCClient

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

func NewGoFlowClient

func NewGoFlowClient(connString string, opt ...GoFlowGRPCClientOption) (*GoFlowGRPCClient, error)

func (*GoFlowGRPCClient) Get

func (g *GoFlowGRPCClient) Get(taskID string) (string, error)

func (*GoFlowGRPCClient) Push

func (g *GoFlowGRPCClient) Push(taskType, payload string) (string, error)

type GoFlowGRPCClientOption

type GoFlowGRPCClientOption interface {
	// contains filtered or unexported methods
}

A GoFlowGRPCClientOption sets options such as logger, request timeout, etc.

func WithLogger

func WithLogger(logger log.Logger) GoFlowGRPCClientOption

WithLogger allows you to set logger that will report on basic server start/stop operations.

func WithRequestTimeout

func WithRequestTimeout(requestTimeout time.Duration) GoFlowGRPCClientOption

WithRequestTimeout allows you to set the time the client will wait after sending a request before timing out.