memory

Documentation

Index

• Constants
• type InMemoryPubSubConfig
  • func InMemoryPubSubConfigFromMap(properties map[string]string) (InMemoryPubSubConfig, error)
• type InMemoryPubSubProvider
  • func (a *InMemoryPubSubProvider) Clone(config providers.IProviderConfig) (providers.IProvider, error)
  • func (v *InMemoryPubSubProvider) ID() string
  • func (i *InMemoryPubSubProvider) Init(config providers.IProviderConfig) error
  • func (i *InMemoryPubSubProvider) InitWithMap(properties map[string]string) error
  • func (i *InMemoryPubSubProvider) Publish(topic string, event v1alpha2.Event) error
  • func (s *InMemoryPubSubProvider) SetContext(ctx *contexts.ManagerContext)
  • func (i *InMemoryPubSubProvider) Subscribe(topic string, handler v1alpha2.EventHandler) error

Constants

const (
	DefaultRetryCount      = 5
	DefaultRetryWaitSecond = 10
)

Types

type InMemoryPubSubConfig

type InMemoryPubSubConfig struct {
	Name                      string `json:"name"`
	SubscriberRetryCount      int    `json:"subscriberRetryCount"`
	SubscriberRetryWaitSecond int    `json:"subscriberRetryWaitSecond"`
}

func InMemoryPubSubConfigFromMap

func InMemoryPubSubConfigFromMap(properties map[string]string) (InMemoryPubSubConfig, error)

type InMemoryPubSubProvider

type InMemoryPubSubProvider struct {
	Config      InMemoryPubSubConfig               `json:"config"`
	Subscribers map[string][]v1alpha2.EventHandler `json:"subscribers"`
	Context     *contexts.ManagerContext
}

func (*InMemoryPubSubProvider) Clone

func (a *InMemoryPubSubProvider) Clone(config providers.IProviderConfig) (providers.IProvider, error)

func (*InMemoryPubSubProvider) ID

func (v *InMemoryPubSubProvider) ID() string

func (*InMemoryPubSubProvider) Init

func (i *InMemoryPubSubProvider) Init(config providers.IProviderConfig) error

func (*InMemoryPubSubProvider) InitWithMap

func (i *InMemoryPubSubProvider) InitWithMap(properties map[string]string) error

func (*InMemoryPubSubProvider) Publish

func (i *InMemoryPubSubProvider) Publish(topic string, event v1alpha2.Event) error

func (*InMemoryPubSubProvider) SetContext

func (s *InMemoryPubSubProvider) SetContext(ctx *contexts.ManagerContext)

func (*InMemoryPubSubProvider) Subscribe

func (i *InMemoryPubSubProvider) Subscribe(topic string, handler v1alpha2.EventHandler) error