direct

Documentation

Index

• type DaemonDirector
  • func NewDaemonDirector(ctx context.Context, s Send, r DaemonRecv) DaemonDirector
• type DaemonRecv
• type IdGetSetter
• type IdGetter
• type Request
• type Response
• type Send
• type SrvDirector
  • func NewSrvDirector(ctx context.Context, s Send, r SrvRecv) SrvDirector
• type SrvRecv

Types

type DaemonDirector

type DaemonDirector interface {
	Start() error
	Direct(IdGetSetter) (any, error)
	WatcherDirect(IdGetSetter) (<-chan IdGetter, error)
}

func NewDaemonDirector

func NewDaemonDirector(ctx context.Context, s Send, r DaemonRecv) DaemonDirector

type DaemonRecv

type DaemonRecv func() (Response, error)

type IdGetSetter

type IdGetSetter interface {
	IdGetter
	// contains filtered or unexported methods
}

type IdGetter

type IdGetter interface {
	GetId() string
}

type Request

type Request interface {
	IdGetter
	// contains filtered or unexported methods
}

type Response

type Response interface {
	IdGetter
}

type Send

type Send func(any) error

type SrvDirector

type SrvDirector interface {
	Direct(IdGetter) error
	WatcherDirect(<-chan IdGetter) error
	Outlet() <-chan Request
	Start() error
}

func NewSrvDirector

func NewSrvDirector(ctx context.Context, s Send, r SrvRecv) SrvDirector

type SrvRecv

type SrvRecv func() (Request, error)