jetflow

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

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

type HandlerFactory func(id string) OperatorHandler

type HandlerFactoryMapping map[string]HandlerFactory

type Method string

type Operator interface {
	ID() string
}

type OperatorClient interface {
	Find(ctx context.Context, id string, operator interface{}) error
	Call(context.Context, *Request) (res []byte, err error)
}

type OperatorHandler interface {
	Handle(context.Context, OperatorClient, *Request) ([]byte, error)
}

type ProxyFactory func(id string, client OperatorClient) Operator

type ProxyFactoryMapping map[string]ProxyFactory

type Publisher interface {
	Publish(context.Context, *Request) (chan *Response, error)
}

type Request struct {
	TransactionID string `json:"o"`
	RequestID     string `json:"r"`

	TypeName   string `json:"n"`
	InstanceID string `json:"i"`
	Method     string `json:"m"`
	Args       []byte `json:"a"`
}

type RequestHandler interface {
	Handle(context.Context, *Request) *Response
}

type Response struct {
	RequestID         string
	InvolvedOperators map[string]map[string]bool

	Values []byte
	Error  error
}

type Storage interface {
	Get(context.Context, *Request) (OperatorHandler, error)
	Prepare(context.Context, *Request) error
	Commit(context.Context, *Request) error
	Rollback(context.Context, *Request) error
}