core

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: Apr 6, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Bus

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

func New

func New(ctx context.Context, log logr.Logger, opts ...Option) (*Bus, error)

func (*Bus) Close

func (b *Bus) Close() error

func (*Bus) Send

func (b *Bus) Send(ctx context.Context, req *Message) (*SendResp, error)

type Channel

type Channel int
const (
	None Channel = iota
	Letter
	Email
)

func (Channel) String

func (i Channel) String() string

type Message

type Message struct {
	event.Data `json:",omitempty"`
}

type Option

type Option func(*Bus) error

func WithPubsubName

func WithPubsubName(pubsubName string) Option

func WithTenant

func WithTenant(tenant string) Option

type SendResp

type SendResp struct{}

Jump to

Keyboard shortcuts

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