notification

Documentation

Index

• func FromConfigPb(impl *protobufs.DatabaseNotificationConfig) data.NotificationConfig
• func FromPb(impl *protobufs.DatabaseNotification) data.Notification
• func NewCallback(fn func(context.Context, data.Notification)) data.NotificationCallback
• func NewConfig() data.NotificationConfig
• func NewToken(subscriptionId string, store data.Store, callback data.NotificationCallback) data.NotificationToken
• func ToConfigPb(n data.NotificationConfig) *protobufs.DatabaseNotificationConfig
• func ToPb(n data.Notification) *protobufs.DatabaseNotification
• type Callback
  • func (c *Callback) Fn(ctx context.Context, n data.Notification)
  • func (c *Callback) Id() string
• type ConfigWrapper
  • func (c *ConfigWrapper) GetContextFields() []string
  • func (c *ConfigWrapper) GetEntityId() string
  • func (c *ConfigWrapper) GetEntityType() string
  • func (c *ConfigWrapper) GetFieldName() string
  • func (c *ConfigWrapper) GetNotifyOnChange() bool
  • func (c *ConfigWrapper) GetServiceId() string
  • func (c *ConfigWrapper) SetContextFields(cf []string) data.NotificationConfig
  • func (c *ConfigWrapper) SetEntityId(id string) data.NotificationConfig
  • func (c *ConfigWrapper) SetEntityType(t string) data.NotificationConfig
  • func (c *ConfigWrapper) SetFieldName(f string) data.NotificationConfig
  • func (c *ConfigWrapper) SetNotifyOnChange(no bool) data.NotificationConfig
  • func (c *ConfigWrapper) SetServiceId(si string) data.NotificationConfig
• type NotificationWrapper
  • func (n *NotificationWrapper) GetContext(index int) data.Field
  • func (n *NotificationWrapper) GetContextCount() int
  • func (n *NotificationWrapper) GetCurrent() data.Field
  • func (n *NotificationWrapper) GetPrevious() data.Field
  • func (n *NotificationWrapper) GetToken() string
• type Token
  • func (t *Token) Id() string
  • func (t *Token) Unbind(ctx context.Context)

Functions

func FromConfigPb

func FromConfigPb(impl *protobufs.DatabaseNotificationConfig) data.NotificationConfig

func FromPb

func FromPb(impl *protobufs.DatabaseNotification) data.Notification

func NewCallback

func NewCallback(fn func(context.Context, data.Notification)) data.NotificationCallback

func NewConfig

func NewConfig() data.NotificationConfig

func NewToken

func NewToken(subscriptionId string, store data.Store, callback data.NotificationCallback) data.NotificationToken

func ToConfigPb

func ToConfigPb(n data.NotificationConfig) *protobufs.DatabaseNotificationConfig

func ToPb

func ToPb(n data.Notification) *protobufs.DatabaseNotification

Types

type Callback

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

func (*Callback) Fn

func (c *Callback) Fn(ctx context.Context, n data.Notification)

func (*Callback) Id

func (c *Callback) Id() string

type ConfigWrapper

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

func (*ConfigWrapper) GetContextFields

func (c *ConfigWrapper) GetContextFields() []string

func (*ConfigWrapper) GetEntityId

func (c *ConfigWrapper) GetEntityId() string

func (*ConfigWrapper) GetEntityType

func (c *ConfigWrapper) GetEntityType() string

func (*ConfigWrapper) GetFieldName

func (c *ConfigWrapper) GetFieldName() string

func (*ConfigWrapper) GetNotifyOnChange

func (c *ConfigWrapper) GetNotifyOnChange() bool

func (*ConfigWrapper) GetServiceId

func (c *ConfigWrapper) GetServiceId() string

func (*ConfigWrapper) SetContextFields

func (c *ConfigWrapper) SetContextFields(cf []string) data.NotificationConfig

func (*ConfigWrapper) SetEntityId

func (c *ConfigWrapper) SetEntityId(id string) data.NotificationConfig

func (*ConfigWrapper) SetEntityType

func (c *ConfigWrapper) SetEntityType(t string) data.NotificationConfig

func (*ConfigWrapper) SetFieldName

func (c *ConfigWrapper) SetFieldName(f string) data.NotificationConfig

func (*ConfigWrapper) SetNotifyOnChange

func (c *ConfigWrapper) SetNotifyOnChange(no bool) data.NotificationConfig

func (*ConfigWrapper) SetServiceId

func (c *ConfigWrapper) SetServiceId(si string) data.NotificationConfig

type NotificationWrapper

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

func (*NotificationWrapper) GetContext

func (n *NotificationWrapper) GetContext(index int) data.Field

func (*NotificationWrapper) GetContextCount

func (n *NotificationWrapper) GetContextCount() int

func (*NotificationWrapper) GetCurrent

func (n *NotificationWrapper) GetCurrent() data.Field

func (*NotificationWrapper) GetPrevious

func (n *NotificationWrapper) GetPrevious() data.Field

func (*NotificationWrapper) GetToken

func (n *NotificationWrapper) GetToken() string

type Token

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

func (*Token) Id

func (t *Token) Id() string

func (*Token) Unbind

func (t *Token) Unbind(ctx context.Context)