Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

api_v1

package

Go to main page

Versions in this module

v0

v0.0.4-beta

Nov 20, 2022

v0.0.3

Jan 5, 2023

v0.0.3-beta

Dec 17, 2022

v0.0.2

Jan 1, 2023

Changes in this version

+ var Action_Type_name = map[int32]string

+ var Action_Type_value = map[string]int32

type Action

+ Type Action_Type

+ func (x *Action) GetType() Action_Type

+ type Action_Type int32

+ const Action_SYSTEM

+ const Action_USER

+ func (Action_Type) Descriptor() protoreflect.EnumDescriptor

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

+ func (Action_Type) Type() protoreflect.EnumType

+ func (x Action_Type) Enum() *Action_Type

+ func (x Action_Type) Number() protoreflect.EnumNumber

+ func (x Action_Type) String() string

v0.0.2-beta

Oct 26, 2022

v0.0.1

Dec 26, 2022

Changes in this version

+ var ActionResult_Status_name = map[int32]string

+ var ActionResult_Status_value = map[string]int32

+ var ActionService_ServiceDesc = grpc.ServiceDesc

+ var File_api_v1_flow_proto protoreflect.FileDescriptor

+ func RegisterActionServiceServer(s grpc.ServiceRegistrar, srv ActionServiceServer)

+ type Action struct

+ ActionId int32

+ ActionName string

+ Data map[string]*structpb.Value

+ FlowId string

+ RetryCount int32

+ WorkflowName string

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

+ func (*Action) ProtoMessage()

+ func (x *Action) GetActionId() int32

+ func (x *Action) GetActionName() string

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

+ func (x *Action) GetFlowId() string

+ func (x *Action) GetRetryCount() int32

+ func (x *Action) GetWorkflowName() string

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

+ func (x *Action) Reset()

+ func (x *Action) String() string

+ type ActionDefinition struct

+ Name string

+ RetryAfterSeconds int32

+ RetryCount int32

+ RetryPolicy string

+ TimeoutSeconds int32

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

+ func (*ActionDefinition) ProtoMessage()

+ func (x *ActionDefinition) GetName() string

+ func (x *ActionDefinition) GetRetryAfterSeconds() int32

+ func (x *ActionDefinition) GetRetryCount() int32

+ func (x *ActionDefinition) GetRetryPolicy() string

+ func (x *ActionDefinition) GetTimeoutSeconds() int32

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

+ func (x *ActionDefinition) Reset()

+ func (x *ActionDefinition) String() string

+ type ActionDefinitionSaveResponse struct

+ Status bool

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

+ func (*ActionDefinitionSaveResponse) ProtoMessage()

+ func (x *ActionDefinitionSaveResponse) GetStatus() bool

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

+ func (x *ActionDefinitionSaveResponse) Reset()

+ func (x *ActionDefinitionSaveResponse) String() string

+ type ActionPollRequest struct

+ ActionType string

+ BatchSize int32

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

+ func (*ActionPollRequest) ProtoMessage()

+ func (x *ActionPollRequest) GetActionType() string

+ func (x *ActionPollRequest) GetBatchSize() int32

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

+ func (x *ActionPollRequest) Reset()

+ func (x *ActionPollRequest) String() string

+ type ActionResult struct

+ ActionId int32

+ ActionName string

+ Data map[string]*structpb.Value

+ FlowId string

+ RetryCount int32

+ Status ActionResult_Status

+ WorkflowName string

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

+ func (*ActionResult) ProtoMessage()

+ func (x *ActionResult) GetActionId() int32

+ func (x *ActionResult) GetActionName() string

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

+ func (x *ActionResult) GetFlowId() string

+ func (x *ActionResult) GetRetryCount() int32

+ func (x *ActionResult) GetStatus() ActionResult_Status

+ func (x *ActionResult) GetWorkflowName() string

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

+ func (x *ActionResult) Reset()

+ func (x *ActionResult) String() string

+ type ActionResultPushResponse struct

+ Status bool

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

+ func (*ActionResultPushResponse) ProtoMessage()

+ func (x *ActionResultPushResponse) GetStatus() bool

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

+ func (x *ActionResultPushResponse) Reset()

+ func (x *ActionResultPushResponse) String() string

+ type ActionResult_Status int32

+ const ActionResult_FAIL

+ const ActionResult_SUCCESS

+ func (ActionResult_Status) Descriptor() protoreflect.EnumDescriptor

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

+ func (ActionResult_Status) Type() protoreflect.EnumType

+ func (x ActionResult_Status) Enum() *ActionResult_Status

+ func (x ActionResult_Status) Number() protoreflect.EnumNumber

+ func (x ActionResult_Status) String() string

+ type ActionServiceClient interface

+ GetServers func(ctx context.Context, in *GetServersRequest, opts ...grpc.CallOption) (*GetServersResponse, error)

+ Poll func(ctx context.Context, in *ActionPollRequest, opts ...grpc.CallOption) (*Actions, error)

+ Push func(ctx context.Context, in *ActionResult, opts ...grpc.CallOption) (*ActionResultPushResponse, error)

+ SaveActionDefinition func(ctx context.Context, in *ActionDefinition, opts ...grpc.CallOption) (*ActionDefinitionSaveResponse, error)

+ func NewActionServiceClient(cc grpc.ClientConnInterface) ActionServiceClient

+ type ActionServiceServer interface

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

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

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

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

+ type Actions struct

+ Actions []*Action

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

+ func (*Actions) ProtoMessage()

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

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

+ func (x *Actions) Reset()

+ func (x *Actions) String() string

+ type GetServersRequest struct

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

+ func (*GetServersRequest) ProtoMessage()

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

+ func (x *GetServersRequest) Reset()

+ func (x *GetServersRequest) String() string

+ type GetServersResponse struct

+ Servers []*Server

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

+ func (*GetServersResponse) ProtoMessage()

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

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

+ func (x *GetServersResponse) Reset()

+ func (x *GetServersResponse) String() string

+ type Server struct

+ Id string

+ RpcAddr string

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

+ func (*Server) ProtoMessage()

+ func (x *Server) GetId() string

+ func (x *Server) GetRpcAddr() string

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

+ func (x *Server) Reset()

+ func (x *Server) String() string

+ type StorageLayerError struct

+ func (e StorageLayerError) Error() string

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

+ type UnimplementedActionServiceServer struct

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

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

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

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

+ type UnsafeActionServiceServer interface

v0.0.1-beta

Oct 24, 2022

v0.0.0-beta.2

Oct 3, 2022

v0.0.0-beta.1

Jul 25, 2022

v0.0.0-beta

Oct 7, 2022

Other modules containing this package

github.com/mohitkumar/orchy