pb

type AwaitResponse struct {

	// Types that are assignable to Result:
	//
	//	*AwaitResponse_Resolved
	//	*AwaitResponse_Rejected
	Result isAwaitResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

type AwaitResponse_Rejected struct {
	Rejected *Error `protobuf:"bytes,2,opt,name=rejected,proto3,oneof"`
}

type AwaitResponse_Resolved struct {
	Resolved *empty.Empty `protobuf:"bytes,1,opt,name=resolved,proto3,oneof"`
}

type Error struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type FutureClient interface {
	// Create creates a new future, returning a token that can be used to
	// indentify the future in subsequent calls.
	Create(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*wrappers.BytesValue, error)
	// Resolve resolves the future.
	Resolve(ctx context.Context, in *wrappers.BytesValue, opts ...grpc.CallOption) (*empty.Empty, error)
	// Reject rejects the future with an error message.
	Reject(ctx context.Context, in *RejectRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Delete deletes the future.
	Delete(ctx context.Context, in *wrappers.BytesValue, opts ...grpc.CallOption) (*empty.Empty, error)
	// Await blocks until the future is resolved or rejected.
	Await(ctx context.Context, in *wrappers.BytesValue, opts ...grpc.CallOption) (*AwaitResponse, error)
	// Status returns the status of the future (without blocking).
	Status(ctx context.Context, in *wrappers.BytesValue, opts ...grpc.CallOption) (*StatusResponse, error)
}

type FutureServer interface {
	// Create creates a new future, returning a token that can be used to
	// indentify the future in subsequent calls.
	Create(context.Context, *empty.Empty) (*wrappers.BytesValue, error)
	// Resolve resolves the future.
	Resolve(context.Context, *wrappers.BytesValue) (*empty.Empty, error)
	// Reject rejects the future with an error message.
	Reject(context.Context, *RejectRequest) (*empty.Empty, error)
	// Delete deletes the future.
	Delete(context.Context, *wrappers.BytesValue) (*empty.Empty, error)
	// Await blocks until the future is resolved or rejected.
	Await(context.Context, *wrappers.BytesValue) (*AwaitResponse, error)
	// Status returns the status of the future (without blocking).
	Status(context.Context, *wrappers.BytesValue) (*StatusResponse, error)
	// contains filtered or unexported methods
}

type FutureStatus int32

type RejectRequest struct {
	Id     []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Reason *Error `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse struct {
	Status FutureStatus `protobuf:"varint,1,opt,name=status,proto3,enum=offloaded.evently.FutureStatus" json:"status,omitempty"`
	Error  *Error       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type StoredFuture struct {
	Id      []byte               `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Created *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
	Status  FutureStatus         `protobuf:"varint,3,opt,name=status,proto3,enum=offloaded.evently.FutureStatus" json:"status,omitempty"`
	Reason  *Error               `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedFutureServer struct {
}

type UnsafeFutureServer interface {
	// contains filtered or unexported methods
}