temporal

Documentation

Index

• Constants
• type Client
  • func NewTemporalClient(opts *ClientOpts) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) GetBroadcastAddress() string
  • func (c *Client) GetClient(queueName string) (client.Client, error)
  • func (c *Client) GetOpts() *ClientOpts
• type ClientOpts

Constants

const DefaultQueueName = "default"

Types

type Client

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

func NewTemporalClient

func NewTemporalClient(opts *ClientOpts) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) GetBroadcastAddress

func (c *Client) GetBroadcastAddress() string

func (*Client) GetClient

func (c *Client) GetClient(queueName string) (client.Client, error)

func (*Client) GetOpts

func (c *Client) GetOpts() *ClientOpts

type ClientOpts

type ClientOpts struct {
	BroadcastAddress string
	HostPort         string
	Namespace        string
	BearerToken      string
	DefaultQueueName string

	ClientKeyFile  string
	ClientCertFile string
	RootCAFile     string
	TLSServerName  string
}