workflowarchive

package
v0.0.0-...-d372783 Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2020 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Overview

Package workflowarchive is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkflowArchive        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflowArchive          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflowArchive = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterArchivedWorkflowServiceHandler 

func RegisterArchivedWorkflowServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterArchivedWorkflowServiceHandler registers the http handlers for service ArchivedWorkflowService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterArchivedWorkflowServiceHandlerClient 

func RegisterArchivedWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ArchivedWorkflowServiceClient) error

RegisterArchivedWorkflowServiceHandlerClient registers the http handlers for service ArchivedWorkflowService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ArchivedWorkflowServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ArchivedWorkflowServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ArchivedWorkflowServiceClient" to call the correct interceptors.

func RegisterArchivedWorkflowServiceHandlerFromEndpoint 

func RegisterArchivedWorkflowServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterArchivedWorkflowServiceHandlerFromEndpoint is same as RegisterArchivedWorkflowServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterArchivedWorkflowServiceHandlerServer 

func RegisterArchivedWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ArchivedWorkflowServiceServer) error

RegisterArchivedWorkflowServiceHandlerServer registers the http handlers for service ArchivedWorkflowService to "mux". UnaryRPC :call ArchivedWorkflowServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterArchivedWorkflowServiceServer 

func RegisterArchivedWorkflowServiceServer(s *grpc.Server, srv ArchivedWorkflowServiceServer)

Types

type ArchivedWorkflowDeletedResponse 

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

func (*ArchivedWorkflowDeletedResponse) Descriptor 

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

func (*ArchivedWorkflowDeletedResponse) Marshal 

func (m *ArchivedWorkflowDeletedResponse) Marshal() (dAtA []byte, err error)

func (*ArchivedWorkflowDeletedResponse) MarshalTo 

func (m *ArchivedWorkflowDeletedResponse) MarshalTo(dAtA []byte) (int, error)

func (*ArchivedWorkflowDeletedResponse) MarshalToSizedBuffer 

func (m *ArchivedWorkflowDeletedResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ArchivedWorkflowDeletedResponse) ProtoMessage 

func (*ArchivedWorkflowDeletedResponse) ProtoMessage()

func (*ArchivedWorkflowDeletedResponse) Reset 

func (m *ArchivedWorkflowDeletedResponse) Reset()

func (*ArchivedWorkflowDeletedResponse) Size 

func (m *ArchivedWorkflowDeletedResponse) Size() (n int)

func (*ArchivedWorkflowDeletedResponse) String 

func (m *ArchivedWorkflowDeletedResponse) String() string

func (*ArchivedWorkflowDeletedResponse) Unmarshal 

func (m *ArchivedWorkflowDeletedResponse) Unmarshal(dAtA []byte) error

func (*ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown 

func (m *ArchivedWorkflowDeletedResponse) XXX_DiscardUnknown()

func (*ArchivedWorkflowDeletedResponse) XXX_Marshal 

func (m *ArchivedWorkflowDeletedResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ArchivedWorkflowDeletedResponse) XXX_Merge 

func (m *ArchivedWorkflowDeletedResponse) XXX_Merge(src proto.Message)

func (*ArchivedWorkflowDeletedResponse) XXX_Size 

func (m *ArchivedWorkflowDeletedResponse) XXX_Size() int

func (*ArchivedWorkflowDeletedResponse) XXX_Unmarshal 

func (m *ArchivedWorkflowDeletedResponse) XXX_Unmarshal(b []byte) error

type ArchivedWorkflowServiceClient 

type ArchivedWorkflowServiceClient interface {
	ListArchivedWorkflows(ctx context.Context, in *ListArchivedWorkflowsRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(ctx context.Context, in *GetArchivedWorkflowRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(ctx context.Context, in *DeleteArchivedWorkflowRequest, opts ...grpc.CallOption) (*ArchivedWorkflowDeletedResponse, error)
}

ArchivedWorkflowServiceClient is the client API for ArchivedWorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewArchivedWorkflowServiceClient 

func NewArchivedWorkflowServiceClient(cc *grpc.ClientConn) ArchivedWorkflowServiceClient

type ArchivedWorkflowServiceServer 

type ArchivedWorkflowServiceServer interface {
	ListArchivedWorkflows(context.Context, *ListArchivedWorkflowsRequest) (*v1alpha1.WorkflowList, error)
	GetArchivedWorkflow(context.Context, *GetArchivedWorkflowRequest) (*v1alpha1.Workflow, error)
	DeleteArchivedWorkflow(context.Context, *DeleteArchivedWorkflowRequest) (*ArchivedWorkflowDeletedResponse, error)
}

ArchivedWorkflowServiceServer is the server API for ArchivedWorkflowService service.

func NewWorkflowArchiveServer 

func NewWorkflowArchiveServer(wfArchive sqldb.WorkflowArchive) ArchivedWorkflowServiceServer

type DeleteArchivedWorkflowRequest 

type DeleteArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteArchivedWorkflowRequest) Descriptor 

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

func (*DeleteArchivedWorkflowRequest) GetUid 

func (m *DeleteArchivedWorkflowRequest) GetUid() string

func (*DeleteArchivedWorkflowRequest) Marshal 

func (m *DeleteArchivedWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*DeleteArchivedWorkflowRequest) MarshalTo 

func (m *DeleteArchivedWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteArchivedWorkflowRequest) MarshalToSizedBuffer 

func (m *DeleteArchivedWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteArchivedWorkflowRequest) ProtoMessage 

func (*DeleteArchivedWorkflowRequest) ProtoMessage()

func (*DeleteArchivedWorkflowRequest) Reset 

func (m *DeleteArchivedWorkflowRequest) Reset()

func (*DeleteArchivedWorkflowRequest) Size 

func (m *DeleteArchivedWorkflowRequest) Size() (n int)

func (*DeleteArchivedWorkflowRequest) String 

func (m *DeleteArchivedWorkflowRequest) String() string

func (*DeleteArchivedWorkflowRequest) Unmarshal 

func (m *DeleteArchivedWorkflowRequest) Unmarshal(dAtA []byte) error

func (*DeleteArchivedWorkflowRequest) XXX_DiscardUnknown 

func (m *DeleteArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*DeleteArchivedWorkflowRequest) XXX_Marshal 

func (m *DeleteArchivedWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DeleteArchivedWorkflowRequest) XXX_Merge 

func (m *DeleteArchivedWorkflowRequest) XXX_Merge(src proto.Message)

func (*DeleteArchivedWorkflowRequest) XXX_Size 

func (m *DeleteArchivedWorkflowRequest) XXX_Size() int

func (*DeleteArchivedWorkflowRequest) XXX_Unmarshal 

func (m *DeleteArchivedWorkflowRequest) XXX_Unmarshal(b []byte) error

type GetArchivedWorkflowRequest 

type GetArchivedWorkflowRequest struct {
	Uid                  string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetArchivedWorkflowRequest) Descriptor 

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

func (*GetArchivedWorkflowRequest) GetUid 

func (m *GetArchivedWorkflowRequest) GetUid() string

func (*GetArchivedWorkflowRequest) Marshal 

func (m *GetArchivedWorkflowRequest) Marshal() (dAtA []byte, err error)

func (*GetArchivedWorkflowRequest) MarshalTo 

func (m *GetArchivedWorkflowRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetArchivedWorkflowRequest) MarshalToSizedBuffer 

func (m *GetArchivedWorkflowRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetArchivedWorkflowRequest) ProtoMessage 

func (*GetArchivedWorkflowRequest) ProtoMessage()

func (*GetArchivedWorkflowRequest) Reset 

func (m *GetArchivedWorkflowRequest) Reset()

func (*GetArchivedWorkflowRequest) Size 

func (m *GetArchivedWorkflowRequest) Size() (n int)

func (*GetArchivedWorkflowRequest) String 

func (m *GetArchivedWorkflowRequest) String() string

func (*GetArchivedWorkflowRequest) Unmarshal 

func (m *GetArchivedWorkflowRequest) Unmarshal(dAtA []byte) error

func (*GetArchivedWorkflowRequest) XXX_DiscardUnknown 

func (m *GetArchivedWorkflowRequest) XXX_DiscardUnknown()

func (*GetArchivedWorkflowRequest) XXX_Marshal 

func (m *GetArchivedWorkflowRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetArchivedWorkflowRequest) XXX_Merge 

func (m *GetArchivedWorkflowRequest) XXX_Merge(src proto.Message)

func (*GetArchivedWorkflowRequest) XXX_Size 

func (m *GetArchivedWorkflowRequest) XXX_Size() int

func (*GetArchivedWorkflowRequest) XXX_Unmarshal 

func (m *GetArchivedWorkflowRequest) XXX_Unmarshal(b []byte) error

type ListArchivedWorkflowsRequest 

type ListArchivedWorkflowsRequest struct {
	ListOptions          *v1.ListOptions `protobuf:"bytes,1,opt,name=listOptions,proto3" json:"listOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ListArchivedWorkflowsRequest) Descriptor 

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

func (*ListArchivedWorkflowsRequest) GetListOptions 

func (m *ListArchivedWorkflowsRequest) GetListOptions() *v1.ListOptions

func (*ListArchivedWorkflowsRequest) Marshal 

func (m *ListArchivedWorkflowsRequest) Marshal() (dAtA []byte, err error)

func (*ListArchivedWorkflowsRequest) MarshalTo 

func (m *ListArchivedWorkflowsRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListArchivedWorkflowsRequest) MarshalToSizedBuffer 

func (m *ListArchivedWorkflowsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListArchivedWorkflowsRequest) ProtoMessage 

func (*ListArchivedWorkflowsRequest) ProtoMessage()

func (*ListArchivedWorkflowsRequest) Reset 

func (m *ListArchivedWorkflowsRequest) Reset()

func (*ListArchivedWorkflowsRequest) Size 

func (m *ListArchivedWorkflowsRequest) Size() (n int)

func (*ListArchivedWorkflowsRequest) String 

func (m *ListArchivedWorkflowsRequest) String() string

func (*ListArchivedWorkflowsRequest) Unmarshal 

func (m *ListArchivedWorkflowsRequest) Unmarshal(dAtA []byte) error

func (*ListArchivedWorkflowsRequest) XXX_DiscardUnknown 

func (m *ListArchivedWorkflowsRequest) XXX_DiscardUnknown()

func (*ListArchivedWorkflowsRequest) XXX_Marshal 

func (m *ListArchivedWorkflowsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListArchivedWorkflowsRequest) XXX_Merge 

func (m *ListArchivedWorkflowsRequest) XXX_Merge(src proto.Message)

func (*ListArchivedWorkflowsRequest) XXX_Size 

func (m *ListArchivedWorkflowsRequest) XXX_Size() int

func (*ListArchivedWorkflowsRequest) XXX_Unmarshal 

func (m *ListArchivedWorkflowsRequest) XXX_Unmarshal(b []byte) error

type UnimplementedArchivedWorkflowServiceServer 

type UnimplementedArchivedWorkflowServiceServer struct {
}

UnimplementedArchivedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedArchivedWorkflowServiceServer) DeleteArchivedWorkflow 

func (*UnimplementedArchivedWorkflowServiceServer) DeleteArchivedWorkflow(ctx context.Context, req *DeleteArchivedWorkflowRequest) (*ArchivedWorkflowDeletedResponse, error)

func (*UnimplementedArchivedWorkflowServiceServer) GetArchivedWorkflow 

func (*UnimplementedArchivedWorkflowServiceServer) GetArchivedWorkflow(ctx context.Context, req *GetArchivedWorkflowRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflows 

func (*UnimplementedArchivedWorkflowServiceServer) ListArchivedWorkflows(ctx context.Context, req *ListArchivedWorkflowsRequest) (*v1alpha1.WorkflowList, error)

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.