api_v1

package
v0.0.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2023 License: Apache-2.0 Imports: 11 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Action_Type_name = map[int32]string{
		0: "SYSTEM",
		1: "USER",
	}
	Action_Type_value = map[string]int32{
		"SYSTEM": 0,
		"USER":   1,
	}
)

Enum value maps for Action_Type.

View Source 
var (
	ActionResult_Status_name = map[int32]string{
		0: "SUCCESS",
		1: "FAIL",
	}
	ActionResult_Status_value = map[string]int32{
		"SUCCESS": 0,
		"FAIL":    1,
	}
)

Enum value maps for ActionResult_Status.

View Source 
var ActionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ActionService",
	HandlerType: (*ActionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SaveActionDefinition",
			Handler:    _ActionService_SaveActionDefinition_Handler,
		},
		{
			MethodName: "Poll",
			Handler:    _ActionService_Poll_Handler,
		},
		{
			MethodName: "Push",
			Handler:    _ActionService_Push_Handler,
		},
		{
			MethodName: "GetServers",
			Handler:    _ActionService_GetServers_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1/flow.proto",
}

ActionService_ServiceDesc is the grpc.ServiceDesc for ActionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_v1_flow_proto protoreflect.FileDescriptor

Functions

func RegisterActionServiceServer 

func RegisterActionServiceServer(s grpc.ServiceRegistrar, srv ActionServiceServer)

Types

type Action 

type Action struct {
	WorkflowName string                     `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	FlowId       string                     `protobuf:"bytes,2,opt,name=flowId,proto3" json:"flowId,omitempty"`
	Data         map[string]*structpb.Value `` /* 149-byte string literal not displayed */
	ActionId     int32                      `protobuf:"varint,4,opt,name=actionId,proto3" json:"actionId,omitempty"`
	ActionName   string                     `protobuf:"bytes,5,opt,name=actionName,proto3" json:"actionName,omitempty"`
	RetryCount   int32                      `protobuf:"varint,6,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	Type         Action_Type                `protobuf:"varint,7,opt,name=type,proto3,enum=Action_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Action) Descriptor deprecated 

func (*Action) Descriptor() ([]byte, []int)

Deprecated: Use Action.ProtoReflect.Descriptor instead.

func (*Action) GetActionId 

func (x *Action) GetActionId() int32

func (*Action) GetActionName 

func (x *Action) GetActionName() string

func (*Action) GetData 

func (x *Action) GetData() map[string]*structpb.Value

func (*Action) GetFlowId 

func (x *Action) GetFlowId() string

func (*Action) GetRetryCount 

func (x *Action) GetRetryCount() int32

func (*Action) GetType added in v0.0.2 

func (x *Action) GetType() Action_Type

func (*Action) GetWorkflowName 

func (x *Action) GetWorkflowName() string

func (*Action) ProtoMessage 

func (*Action) ProtoMessage()

func (*Action) ProtoReflect 

func (x *Action) ProtoReflect() protoreflect.Message

func (*Action) Reset 

func (x *Action) Reset()

func (*Action) String 

func (x *Action) String() string

type ActionDefinition 

type ActionDefinition struct {
	Name              string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	RetryCount        int32  `protobuf:"varint,2,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	RetryAfterSeconds int32  `protobuf:"varint,3,opt,name=retryAfterSeconds,proto3" json:"retryAfterSeconds,omitempty"`
	RetryPolicy       string `protobuf:"bytes,4,opt,name=retryPolicy,proto3" json:"retryPolicy,omitempty"`
	TimeoutSeconds    int32  `protobuf:"varint,5,opt,name=timeoutSeconds,proto3" json:"timeoutSeconds,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDefinition) Descriptor deprecated 

func (*ActionDefinition) Descriptor() ([]byte, []int)

Deprecated: Use ActionDefinition.ProtoReflect.Descriptor instead.

func (*ActionDefinition) GetName 

func (x *ActionDefinition) GetName() string

func (*ActionDefinition) GetRetryAfterSeconds 

func (x *ActionDefinition) GetRetryAfterSeconds() int32

func (*ActionDefinition) GetRetryCount 

func (x *ActionDefinition) GetRetryCount() int32

func (*ActionDefinition) GetRetryPolicy 

func (x *ActionDefinition) GetRetryPolicy() string

func (*ActionDefinition) GetTimeoutSeconds 

func (x *ActionDefinition) GetTimeoutSeconds() int32

func (*ActionDefinition) ProtoMessage 

func (*ActionDefinition) ProtoMessage()

func (*ActionDefinition) ProtoReflect 

func (x *ActionDefinition) ProtoReflect() protoreflect.Message

func (*ActionDefinition) Reset 

func (x *ActionDefinition) Reset()

func (*ActionDefinition) String 

func (x *ActionDefinition) String() string

type ActionDefinitionSaveResponse 

type ActionDefinitionSaveResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionDefinitionSaveResponse) Descriptor deprecated 

func (*ActionDefinitionSaveResponse) Descriptor() ([]byte, []int)

Deprecated: Use ActionDefinitionSaveResponse.ProtoReflect.Descriptor instead.

func (*ActionDefinitionSaveResponse) GetStatus 

func (x *ActionDefinitionSaveResponse) GetStatus() bool

func (*ActionDefinitionSaveResponse) ProtoMessage 

func (*ActionDefinitionSaveResponse) ProtoMessage()

func (*ActionDefinitionSaveResponse) ProtoReflect 

func (x *ActionDefinitionSaveResponse) ProtoReflect() protoreflect.Message

func (*ActionDefinitionSaveResponse) Reset 

func (x *ActionDefinitionSaveResponse) Reset()

func (*ActionDefinitionSaveResponse) String 

func (x *ActionDefinitionSaveResponse) String() string

type ActionPollRequest 

type ActionPollRequest struct {
	ActionType string `protobuf:"bytes,1,opt,name=actionType,proto3" json:"actionType,omitempty"`
	BatchSize  int32  `protobuf:"varint,2,opt,name=batchSize,proto3" json:"batchSize,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionPollRequest) Descriptor deprecated 

func (*ActionPollRequest) Descriptor() ([]byte, []int)

Deprecated: Use ActionPollRequest.ProtoReflect.Descriptor instead.

func (*ActionPollRequest) GetActionType 

func (x *ActionPollRequest) GetActionType() string

func (*ActionPollRequest) GetBatchSize 

func (x *ActionPollRequest) GetBatchSize() int32

func (*ActionPollRequest) ProtoMessage 

func (*ActionPollRequest) ProtoMessage()

func (*ActionPollRequest) ProtoReflect 

func (x *ActionPollRequest) ProtoReflect() protoreflect.Message

func (*ActionPollRequest) Reset 

func (x *ActionPollRequest) Reset()

func (*ActionPollRequest) String 

func (x *ActionPollRequest) String() string

type ActionResult 

type ActionResult struct {
	WorkflowName string                     `protobuf:"bytes,1,opt,name=workflowName,proto3" json:"workflowName,omitempty"`
	ActionName   string                     `protobuf:"bytes,2,opt,name=actionName,proto3" json:"actionName,omitempty"`
	FlowId       string                     `protobuf:"bytes,3,opt,name=flowId,proto3" json:"flowId,omitempty"`
	ActionId     int32                      `protobuf:"varint,4,opt,name=actionId,proto3" json:"actionId,omitempty"`
	Data         map[string]*structpb.Value `` /* 149-byte string literal not displayed */
	Status       ActionResult_Status        `protobuf:"varint,6,opt,name=status,proto3,enum=ActionResult_Status" json:"status,omitempty"`
	RetryCount   int32                      `protobuf:"varint,7,opt,name=retryCount,proto3" json:"retryCount,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionResult) Descriptor deprecated 

func (*ActionResult) Descriptor() ([]byte, []int)

Deprecated: Use ActionResult.ProtoReflect.Descriptor instead.

func (*ActionResult) GetActionId 

func (x *ActionResult) GetActionId() int32

func (*ActionResult) GetActionName 

func (x *ActionResult) GetActionName() string

func (*ActionResult) GetData 

func (x *ActionResult) GetData() map[string]*structpb.Value

func (*ActionResult) GetFlowId 

func (x *ActionResult) GetFlowId() string

func (*ActionResult) GetRetryCount 

func (x *ActionResult) GetRetryCount() int32

func (*ActionResult) GetStatus 

func (x *ActionResult) GetStatus() ActionResult_Status

func (*ActionResult) GetWorkflowName 

func (x *ActionResult) GetWorkflowName() string

func (*ActionResult) ProtoMessage 

func (*ActionResult) ProtoMessage()

func (*ActionResult) ProtoReflect 

func (x *ActionResult) ProtoReflect() protoreflect.Message

func (*ActionResult) Reset 

func (x *ActionResult) Reset()

func (*ActionResult) String 

func (x *ActionResult) String() string

type ActionResultPushResponse 

type ActionResultPushResponse struct {
	Status bool `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ActionResultPushResponse) Descriptor deprecated 

func (*ActionResultPushResponse) Descriptor() ([]byte, []int)

Deprecated: Use ActionResultPushResponse.ProtoReflect.Descriptor instead.

func (*ActionResultPushResponse) GetStatus 

func (x *ActionResultPushResponse) GetStatus() bool

func (*ActionResultPushResponse) ProtoMessage 

func (*ActionResultPushResponse) ProtoMessage()

func (*ActionResultPushResponse) ProtoReflect 

func (x *ActionResultPushResponse) ProtoReflect() protoreflect.Message

func (*ActionResultPushResponse) Reset 

func (x *ActionResultPushResponse) Reset()

func (*ActionResultPushResponse) String 

func (x *ActionResultPushResponse) String() string

type ActionResult_Status 

type ActionResult_Status int32
const (
	ActionResult_SUCCESS ActionResult_Status = 0
	ActionResult_FAIL    ActionResult_Status = 1
)

func (ActionResult_Status) Descriptor 

func (ActionResult_Status) Descriptor() protoreflect.EnumDescriptor

func (ActionResult_Status) Enum 

func (x ActionResult_Status) Enum() *ActionResult_Status

func (ActionResult_Status) EnumDescriptor deprecated 

func (ActionResult_Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use ActionResult_Status.Descriptor instead.

func (ActionResult_Status) Number 

func (x ActionResult_Status) Number() protoreflect.EnumNumber

func (ActionResult_Status) String 

func (x ActionResult_Status) String() string

func (ActionResult_Status) Type 

func (ActionResult_Status) Type() protoreflect.EnumType

type ActionServiceClient 

type ActionServiceClient interface {
	SaveActionDefinition(ctx context.Context, in *ActionDefinition, opts ...grpc.CallOption) (*ActionDefinitionSaveResponse, error)
	Poll(ctx context.Context, in *ActionPollRequest, opts ...grpc.CallOption) (*Actions, error)
	Push(ctx context.Context, in *ActionResult, opts ...grpc.CallOption) (*ActionResultPushResponse, error)
	GetServers(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error)
}

ActionServiceClient is the client API for ActionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewActionServiceClient 

func NewActionServiceClient(cc grpc.ClientConnInterface) ActionServiceClient

type ActionServiceServer 

type ActionServiceServer interface {
	SaveActionDefinition(context.Context, *ActionDefinition) (*ActionDefinitionSaveResponse, error)
	Poll(context.Context, *ActionPollRequest) (*Actions, error)
	Push(context.Context, *ActionResult) (*ActionResultPushResponse, error)
	GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)
	// contains filtered or unexported methods
}

ActionServiceServer is the server API for ActionService service. All implementations must embed UnimplementedActionServiceServer for forward compatibility

type Action_Type added in v0.0.2 

type Action_Type int32
const (
	Action_SYSTEM Action_Type = 0
	Action_USER   Action_Type = 1
)

func (Action_Type) Descriptor added in v0.0.2 

func (Action_Type) Descriptor() protoreflect.EnumDescriptor

func (Action_Type) Enum added in v0.0.2 

func (x Action_Type) Enum() *Action_Type

func (Action_Type) EnumDescriptor deprecated added in v0.0.2 

func (Action_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Action_Type.Descriptor instead.

func (Action_Type) Number added in v0.0.2 

func (x Action_Type) Number() protoreflect.EnumNumber

func (Action_Type) String added in v0.0.2 

func (x Action_Type) String() string

func (Action_Type) Type added in v0.0.2 

func (Action_Type) Type() protoreflect.EnumType

type Actions 

type Actions struct {
	Actions []*Action `protobuf:"bytes,1,rep,name=actions,proto3" json:"actions,omitempty"`
	// contains filtered or unexported fields
}

func (*Actions) Descriptor deprecated 

func (*Actions) Descriptor() ([]byte, []int)

Deprecated: Use Actions.ProtoReflect.Descriptor instead.

func (*Actions) GetActions 

func (x *Actions) GetActions() []*Action

func (*Actions) ProtoMessage 

func (*Actions) ProtoMessage()

func (*Actions) ProtoReflect 

func (x *Actions) ProtoReflect() protoreflect.Message

func (*Actions) Reset 

func (x *Actions) Reset()

func (*Actions) String 

func (x *Actions) String() string

type GetServersRequest 

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

func (*GetServersRequest) Descriptor deprecated 

func (*GetServersRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetServersRequest.ProtoReflect.Descriptor instead.

func (*GetServersRequest) ProtoMessage 

func (*GetServersRequest) ProtoMessage()

func (*GetServersRequest) ProtoReflect 

func (x *GetServersRequest) ProtoReflect() protoreflect.Message

func (*GetServersRequest) Reset 

func (x *GetServersRequest) Reset()

func (*GetServersRequest) String 

func (x *GetServersRequest) String() string

type GetServersResponse 

type GetServersResponse struct {
	Servers []*Server `protobuf:"bytes,1,rep,name=servers,proto3" json:"servers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetServersResponse) Descriptor deprecated 

func (*GetServersResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetServersResponse.ProtoReflect.Descriptor instead.

func (*GetServersResponse) GetServers 

func (x *GetServersResponse) GetServers() []*Server

func (*GetServersResponse) ProtoMessage 

func (*GetServersResponse) ProtoMessage()

func (*GetServersResponse) ProtoReflect 

func (x *GetServersResponse) ProtoReflect() protoreflect.Message

func (*GetServersResponse) Reset 

func (x *GetServersResponse) Reset()

func (*GetServersResponse) String 

func (x *GetServersResponse) String() string

type Server 

type Server struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RpcAddr string `protobuf:"bytes,2,opt,name=rpc_addr,json=rpcAddr,proto3" json:"rpc_addr,omitempty"`
	// contains filtered or unexported fields
}

func (*Server) Descriptor deprecated 

func (*Server) Descriptor() ([]byte, []int)

Deprecated: Use Server.ProtoReflect.Descriptor instead.

func (*Server) GetId 

func (x *Server) GetId() string

func (*Server) GetRpcAddr 

func (x *Server) GetRpcAddr() string

func (*Server) ProtoMessage 

func (*Server) ProtoMessage()

func (*Server) ProtoReflect 

func (x *Server) ProtoReflect() protoreflect.Message

func (*Server) Reset 

func (x *Server) Reset()

func (*Server) String 

func (x *Server) String() string

type StorageLayerError 

type StorageLayerError struct{}

func (StorageLayerError) Error 

func (e StorageLayerError) Error() string

func (StorageLayerError) GRPCStatus 

func (e StorageLayerError) GRPCStatus() *status.Status

type UnimplementedActionServiceServer 

type UnimplementedActionServiceServer struct {
}

UnimplementedActionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedActionServiceServer) GetServers 

func (UnimplementedActionServiceServer) GetServers(context.Context, *GetServersRequest) (*GetServersResponse, error)

func (UnimplementedActionServiceServer) Poll 

func (UnimplementedActionServiceServer) Poll(context.Context, *ActionPollRequest) (*Actions, error)

func (UnimplementedActionServiceServer) Push 

func (UnimplementedActionServiceServer) Push(context.Context, *ActionResult) (*ActionResultPushResponse, error)

func (UnimplementedActionServiceServer) SaveActionDefinition 

func (UnimplementedActionServiceServer) SaveActionDefinition(context.Context, *ActionDefinition) (*ActionDefinitionSaveResponse, error)

type UnsafeActionServiceServer 

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

UnsafeActionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ActionServiceServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.