bus

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 14, 2020 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddDomainBinding

type AddDomainBinding repository.DnsBinding

type ApplicationBus

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

func New

func New() *ApplicationBus

func (*ApplicationBus) Publish

func (a *ApplicationBus) Publish(event interface{})

func (*ApplicationBus) Subscribe

func (a *ApplicationBus) Subscribe(c Consumer)

type Consumer

type Consumer interface {
	Consume(event interface{})
}

type DnsRecordUpdated

type DnsRecordUpdated string

type Publisher

type Publisher interface {
	Publish(event interface{})
	Subscribe(c Consumer)
}

func Get

func Get() Publisher

type RemoveDomainBinding

type RemoveDomainBinding repository.DnsBinding

type RepositoryConsumer

type RepositoryConsumer struct {
	repository.BindingRepository
}

func (RepositoryConsumer) Consume

func (r RepositoryConsumer) Consume(event interface{})

type UpdateDomainBinding

type UpdateDomainBinding repository.DnsBinding

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL