service

type Context interface {
	// Set sends a message to a client machine or other server component. It can be called
	// anytime after Service.Start begins and before Service.Stop returns.
	Send(context.Context, *fspb.Message) error

	// GetClientData retrieves basic information about a client.
	GetClientData(context.Context, common.ClientID) (*db.ClientData, error)
}

type Factory func(*spb.ServiceConfig) (Service, error)

type Service interface {
	// Start tells the service to begin operations. Once started, the service may make
	// calls into ServiceContext until Wait is called.
	Start(sctx Context) error

	// ProcessMessage requests that the service process a message. If it returns a
	// net.Error which reports as a timeout or temporary error, the message will
	// be retried according the ServerRetryPolicy. Otherwise the error will be
	// assumed to be permanent.
	ProcessMessage(context.Context, *fspb.Message) error

	// Stop initiates and waits for an orderly shut down. It will only be
	// called when there are no more active calls to ProcessMessage and
	// should not return until all calls to ServiceContext are completed.
	Stop() error
}

type TemporaryError struct {
	E error
}