service

package
v0.9.0 Latest Latest
Warning

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

 Go to latest Published: Jan 8, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Auth added in v0.4.0 

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

func NewAuth added in v0.4.0 

func NewAuth(cfg *config.Config) *Auth

func (*Auth) AnonymousLogin added in v0.4.0 

func (m *Auth) AnonymousLogin() bool

func (*Auth) Login added in v0.4.0 

func (m *Auth) Login(username, password string) error

type Bridge 

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

func NewBridge 

func NewBridge(cfg *config.Config, endpointREPO core.EndpointRepositoryPort) *Bridge

func (*Bridge) ListByMessage added in v0.5.0 

func (b *Bridge) ListByMessage(msg *core.Message) []*core.Bridge

type Endpoint added in v0.4.0 

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

func NewEndpoint added in v0.4.0 

func NewEndpoint(endpointREPO core.EndpointRepositoryPort, messageSVC core.MessageServicePort) *Endpoint

func (*Endpoint) Process added in v0.6.1 

func (e *Endpoint) Process(msg *core.Message, atts []core.Attachment, bridges []*core.Bridge) error

type Janitor added in v0.8.0 

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

func NewJanitor added in v0.8.0 

func NewJanitor(cfg *config.Config, attachmentREPO core.AttachmentRepositoryPort, messageREPO core.MessageRepositoryPort) *Janitor

func (*Janitor) Run added in v0.8.0 

func (j *Janitor) Run(ctx context.Context, done chan<- struct{})

type Message 

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

func NewMessage 

func NewMessage(
	cfg *config.Config,
	attachmentREPO core.AttachmentRepositoryPort,
	messageREPO core.MessageRepositoryPort,
) *Message

func (*Message) Create 

func (m *Message) Create(subject, from string, to map[string]struct{}, text string) (*core.Message, error)

func (*Message) CreateAttachment added in v0.4.0 

func (m *Message) CreateAttachment(msg *core.Message, name string, data []byte) (*core.Attachment, error)

func (*Message) UpdateStatus added in v0.4.0 

func (m *Message) UpdateStatus(msg *core.Message, status core.Status) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.