internal

Documentation

Index

• type Agent
  • func (a *Agent) HandleSPOE(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message)
  • func (a *Agent) ReplaceApplications(newApps map[string]*Application)
  • func (a *Agent) Serve(l net.Listener) error
• type AppConfig
  • func (a AppConfig) NewApplication() (*Application, error)
• type Application
  • func (a *Application) HandleRequest(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message) (err error)
  • func (a *Application) HandleResponse(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message) (err error)
• type ErrInterrupted
  • func (e ErrInterrupted) Error() string
  • func (e ErrInterrupted) Is(target error) bool

Types

type Agent

type Agent struct {
	Context      context.Context
	Applications map[string]*Application
	Logger       zerolog.Logger
	// contains filtered or unexported fields
}

func (*Agent) HandleSPOE

func (a *Agent) HandleSPOE(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message)

func (*Agent) ReplaceApplications

func (a *Agent) ReplaceApplications(newApps map[string]*Application)

func (*Agent) Serve

func (a *Agent) Serve(l net.Listener) error

type AppConfig

type AppConfig struct {
	Directives     string
	ResponseCheck  bool
	Logger         zerolog.Logger
	TransactionTTL time.Duration
}

func (AppConfig) NewApplication

func (a AppConfig) NewApplication() (*Application, error)

type Application

type Application struct {
	AppConfig
	// contains filtered or unexported fields
}

func (*Application) HandleRequest

func (a *Application) HandleRequest(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message) (err error)

func (*Application) HandleResponse

func (a *Application) HandleResponse(ctx context.Context, writer *encoding.ActionWriter, message *encoding.Message) (err error)

type ErrInterrupted

type ErrInterrupted struct {
	Interruption *types.Interruption
}

func (ErrInterrupted) Error

func (e ErrInterrupted) Error() string

func (ErrInterrupted) Is

func (e ErrInterrupted) Is(target error) bool