Documentation ¶
Index ¶
- type Client
- func (c *Client) Close() error
- func (c *Client) OnConnectionClosed(listener func(context.Context, *proto.ShutdownRequest) error)
- func (c *Client) OnDataStoreTestConnectionRequest(listener func(context.Context, *proto.DataStoreConnectionTestRequest) error)
- func (c *Client) OnPollingRequest(listener func(context.Context, *proto.PollingRequest) error)
- func (c *Client) OnTriggerRequest(listener func(context.Context, *proto.TriggerRequest) error)
- func (c *Client) SendDataStoreConnectionResult(ctx context.Context, response *proto.DataStoreConnectionTestResponse) error
- func (c *Client) SendTrace(ctx context.Context, pollingResponse *proto.PollingResponse) error
- func (c *Client) SendTriggerResponse(ctx context.Context, response *proto.TriggerResponse) error
- func (c *Client) SessionConfiguration() *SessionConfig
- func (c *Client) Start(ctx context.Context) error
- func (c *Client) WaitUntilDisconnected()
- type Config
- type Option
- type SessionConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) OnConnectionClosed ¶
func (*Client) OnDataStoreTestConnectionRequest ¶
func (*Client) OnPollingRequest ¶
func (*Client) OnTriggerRequest ¶
func (*Client) SendDataStoreConnectionResult ¶
func (*Client) SendTriggerResponse ¶
func (*Client) SessionConfiguration ¶
func (c *Client) SessionConfiguration() *SessionConfig
func (*Client) WaitUntilDisconnected ¶
func (c *Client) WaitUntilDisconnected()
type SessionConfig ¶
type SessionConfig struct { BatchTimeout time.Duration AgentIdentification *proto.AgentIdentification }
Source Files ¶
- client.go
- connector.go
- options.go
- workflow_listen_for_ds_connection_tests.go
- workflow_listen_for_poll_requests.go
- workflow_listen_for_trigger_requests.go
- workflow_ping.go
- workflow_send_ds_connection_result.go
- workflow_send_trace.go
- workflow_send_trigger_response.go
- workflow_shutdown.go
- workflow_startup.go
Click to show internal directories.
Click to hide internal directories.