Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + type Controller struct + func NewController() *Controller + func (c *Controller) Await(ctx context.Context, conversation *Conversation) (*Ydb_Coordination.SessionResponse, error) + func (c *Controller) Close(byeConversation *Conversation) + func (c *Controller) OnAttach() + func (c *Controller) OnDetach() + func (c *Controller) OnRecv(resp *Ydb_Coordination.SessionResponse) bool + func (c *Controller) OnSend(ctx context.Context) (*Ydb_Coordination.SessionRequest, error) + func (c *Controller) PushBack(conversation *Conversation) error + func (c *Controller) PushFront(conversation *Conversation) error + type Conversation struct + func NewConversation(request func() *Ydb_Coordination.SessionRequest, opts ...Option) *Conversation + type Option func(c *Conversation) + func WithAcknowledgeFilter(filter ResponseFilter) Option + func WithCancelMessage(...) Option + func WithConflictKey(key string) Option + func WithIdempotence(idempotent bool) Option + func WithResponseFilter(filter ResponseFilter) Option + type ResponseFilter func(request *Ydb_Coordination.SessionRequest, ...) bool