worker

Documentation

Index

• type Client
  • func New(cfg *ClientConfig) *Client
  • func (client *Client) Connect(opts ...grpc.DialOption) (err error)
  • func (client *Client) Disconnect() error
  • func (client *Client) StartEventStream(ctx context.Context, opts ...grpc.CallOption)
• type ClientConfig

Types

type Client

type Client struct {
	Cfg *ClientConfig
	// contains filtered or unexported fields
}

Client that listens for events from the Azure Functions host and executes Golang methods

func New

func New(cfg *ClientConfig) *Client

New returns a new instance of Client

func (*Client) Connect

func (client *Client) Connect(opts ...grpc.DialOption) (err error)

Connect tries to establish a grpc connection with the server

func (*Client) Disconnect

func (client *Client) Disconnect() error

Disconnect closes the connection to the server

func (*Client) StartEventStream

func (client *Client) StartEventStream(ctx context.Context, opts ...grpc.CallOption)

StartEventStream starts listening for messages from the Azure Functions Host

type ClientConfig

type ClientConfig struct {
	Host             string
	Port             int
	WorkerID         string
	RequestID        string
	MaxMessageLength int
}

ClientConfig contains all necessary configuration to connect to the Azure Functions Host