adapter

Documentation

Index

• func RunAdapters(ctx context.Context, c ChoriaFramework, wg *sync.WaitGroup) error
• type ChoriaFramework

Functions

func RunAdapters

func RunAdapters(ctx context.Context, c ChoriaFramework, wg *sync.WaitGroup) error

Types

type ChoriaFramework

type ChoriaFramework interface {
	Configuration() *config.Config
	MiddlewareServers() (servers srvcache.Servers, err error)
	NewConnector(ctx context.Context, servers func() (srvcache.Servers, error), name string, logger *log.Entry) (conn inter.Connector, err error)
	NewRequestFromTransportJSON(payload []byte, skipvalidate bool) (msg protocol.Request, err error)
	NewReplyFromTransportJSON(payload []byte, skipvalidate bool) (msg protocol.Reply, err error)
}