orchestrator

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

type EventClient interface {
	// Stream returns a stream of events that satisfy criteria specified.
	Stream(ctx context.Context, in *EventStreamRequest, opts ...grpc.CallOption) (Event_StreamClient, error)
}

type EventServer interface {
	// Stream returns a stream of events that satisfy criteria specified.
	Stream(*EventStreamRequest, Event_StreamServer) error
}

type EventStreamRequest struct {
	// Filter used to filter a stream of events.
	Filter               *EventStreamRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

type EventStreamRequest_Filter struct {
	// hash to filter events.
	Hash github_com_mesg_foundation_engine_hash.Hash `` /* 140-byte string literal not displayed */
	// instance's hash to filter events.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	// key is the key of the event.
	Key                  string   `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty" validate:"printascii"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Event_StreamClient interface {
	Recv() (*event.Event, error)
	grpc.ClientStream
}

type Event_StreamServer interface {
	Send(*event.Event) error
	grpc.ServerStream
}

type ExecutionClient interface {
	// Create an execution on the blockchain.
	Create(ctx context.Context, in *ExecutionCreateRequest, opts ...grpc.CallOption) (*ExecutionCreateResponse, error)
	// Stream returns a stream of executions that satisfy specified filter.
	Stream(ctx context.Context, in *ExecutionStreamRequest, opts ...grpc.CallOption) (Execution_StreamClient, error)
}

type ExecutionCreateRequest struct {
	TaskKey              string                                      `protobuf:"bytes,1,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"required,printascii"`
	Inputs               *types.Struct                               `protobuf:"bytes,2,opt,name=inputs,proto3" json:"inputs,omitempty"`
	Tags                 []string                                    `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

type ExecutionCreateResponse struct {
	// Execution's hash.
	Hash                 github_com_mesg_foundation_engine_hash.Hash `protobuf:"bytes,1,opt,name=hash,proto3,casttype=github.com/mesg-foundation/engine/hash.Hash" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

type ExecutionServer interface {
	// Create an execution on the blockchain.
	Create(context.Context, *ExecutionCreateRequest) (*ExecutionCreateResponse, error)
	// Stream returns a stream of executions that satisfy specified filter.
	Stream(*ExecutionStreamRequest, Execution_StreamServer) error
}

type ExecutionStreamRequest struct {
	// Filter used to filter a stream of executions.
	Filter               *ExecutionStreamRequest_Filter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                       `json:"-"`
	XXX_unrecognized     []byte                         `json:"-"`
	XXX_sizecache        int32                          `json:"-"`
}

type ExecutionStreamRequest_Filter struct {
	// Statuses to filter executions. One status needs to be present in the execution.
	Statuses []execution.Status `protobuf:"varint,1,rep,packed,name=statuses,proto3,enum=mesg.types.Status" json:"statuses,omitempty"`
	// Instance's hash to filter executions.
	InstanceHash github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	// taskKey to filter executions.
	TaskKey string `protobuf:"bytes,3,opt,name=taskKey,proto3" json:"taskKey,omitempty" validate:"printascii"`
	// tags to filter executions. All tags needs to be present in the execution.
	Tags []string `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty" validate:"dive,printascii"`
	// Executor's hash to filter executions.
	ExecutorHash         github_com_mesg_foundation_engine_hash.Hash `` /* 156-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

type Execution_StreamClient interface {
	Recv() (*execution.Execution, error)
	grpc.ClientStream
}

type Execution_StreamServer interface {
	Send(*execution.Execution) error
	grpc.ServerStream
}

type RunnerClient interface {
	// Register registers a new runner to the Engine.
	// This endpoint should only be called when the runner is ready to receive execution and emit events.
	// This endpoint returns a credential token that must be use to reach the Runner APIs.
	Register(ctx context.Context, in *RunnerRegisterRequest, opts ...grpc.CallOption) (*RunnerRegisterResponse, error)
	// Delete a runner from the blockchain.
	Delete(ctx context.Context, in *RunnerDeleteRequest, opts ...grpc.CallOption) (*RunnerDeleteResponse, error)
}

type RunnerDeleteRequest struct {
	RunnerHash           github_com_mesg_foundation_engine_hash.Hash `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

type RunnerDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RunnerRegisterRequest struct {
	// Service's hash to start the runner with.
	ServiceHash github_com_mesg_foundation_engine_hash.Hash `` /* 153-byte string literal not displayed */
	// Hash of the customized environmental variables (not the ones in the service configuration).
	EnvHash              github_com_mesg_foundation_engine_hash.Hash `` /* 146-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                                    `json:"-"`
	XXX_unrecognized     []byte                                      `json:"-"`
	XXX_sizecache        int32                                       `json:"-"`
}

type RunnerRegisterResponse struct {
	// token to use with the other endpoints of this API.
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RunnerServer interface {
	// Register registers a new runner to the Engine.
	// This endpoint should only be called when the runner is ready to receive execution and emit events.
	// This endpoint returns a credential token that must be use to reach the Runner APIs.
	Register(context.Context, *RunnerRegisterRequest) (*RunnerRegisterResponse, error)
	// Delete a runner from the blockchain.
	Delete(context.Context, *RunnerDeleteRequest) (*RunnerDeleteResponse, error)
}

type UnimplementedEventServer struct {
}

type UnimplementedExecutionServer struct {
}

type UnimplementedRunnerServer struct {
}