grpc_client

Documentation

Index

• type FTaxesClient
  • func NewFTaxesClient(conStr string) *FTaxesClient
  • func (c *FTaxesClient) Connect(ctx context.Context) error
  • func (c *FTaxesClient) PluginHeartbeat(ctx context.Context) error
  • func (c *FTaxesClient) ShowJobProgress(ctx context.Context, job *proto.JobProgress) error
  • func (c *FTaxesClient) StreamRecords(ctx context.Context, job *proto.StreamRecordsJob, out chan *proto.Record) error

Types

type FTaxesClient

type FTaxesClient struct {
	Connection *grpc.ClientConn
	GrpcClient proto.FTaxesClient
	// contains filtered or unexported fields
}

var GrpcClient *FTaxesClient

func NewFTaxesClient

func NewFTaxesClient(conStr string) *FTaxesClient

func (*FTaxesClient) Connect

func (c *FTaxesClient) Connect(ctx context.Context) error

func (*FTaxesClient) PluginHeartbeat

func (c *FTaxesClient) PluginHeartbeat(ctx context.Context) error

func (*FTaxesClient) ShowJobProgress

func (c *FTaxesClient) ShowJobProgress(ctx context.Context, job *proto.JobProgress) error

func (*FTaxesClient) StreamRecords

func (c *FTaxesClient) StreamRecords(ctx context.Context, job *proto.StreamRecordsJob, out chan *proto.Record) error