Documentation ¶
Index ¶
- type Live
- func (c *Live) AckMessages(ackIDs []string) error
- func (c *Live) MakeContext() (context.Context, context.CancelFunc)
- func (c *Live) Pull() ([]SdmEvent, error)
- func (c *Live) WithContext(ctx context.Context) PubSub
- func (c *Live) WithLogMessages() *Live
- func (c *Live) WithMaxMessageAge(d time.Duration) *Live
- func (c *Live) WithServiceAccountCreds(credsFile string) PubSub
- func (c *Live) WithTimeout(d time.Duration) PubSub
- type PubSub
- type SdmEvent
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Live ¶
type Live struct {
// contains filtered or unexported fields
}
func NewLiveClient ¶
func (*Live) AckMessages ¶
func (*Live) MakeContext ¶
func (c *Live) MakeContext() (context.Context, context.CancelFunc)
func (*Live) WithLogMessages ¶
func (*Live) WithServiceAccountCreds ¶
Click to show internal directories.
Click to hide internal directories.