workflow

package
v2.5.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2020 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Overview

Package workflow is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthWorkflow        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWorkflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWorkflow = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterWorkflowServiceHandler 

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

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

func RegisterWorkflowServiceHandlerClient 

func RegisterWorkflowServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WorkflowServiceClient) error

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

func RegisterWorkflowServiceHandlerFromEndpoint 

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

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

func RegisterWorkflowServiceHandlerServer 

func RegisterWorkflowServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WorkflowServiceServer) error

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

func RegisterWorkflowServiceServer 

func RegisterWorkflowServiceServer(s *grpc.Server, srv WorkflowServiceServer)

Types

type LogEntry 

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

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetContent 

func (m *LogEntry) GetContent() string

func (*LogEntry) Marshal 

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

func (*LogEntry) MarshalTo 

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

func (*LogEntry) MarshalToSizedBuffer 

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

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) Size 

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

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) Unmarshal 

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

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowServiceServer) CreateWorkflow 

func (*UnimplementedWorkflowServiceServer) CreateWorkflow(ctx context.Context, req *WorkflowCreateRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow 

func (*UnimplementedWorkflowServiceServer) DeleteWorkflow(ctx context.Context, req *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error)

func (*UnimplementedWorkflowServiceServer) GetWorkflow 

func (*UnimplementedWorkflowServiceServer) GetWorkflow(ctx context.Context, req *WorkflowGetRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) LintWorkflow 

func (*UnimplementedWorkflowServiceServer) LintWorkflow(ctx context.Context, req *WorkflowLintRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) ListWorkflows 

func (*UnimplementedWorkflowServiceServer) ListWorkflows(ctx context.Context, req *WorkflowListRequest) (*v1alpha1.WorkflowList, error)

func (*UnimplementedWorkflowServiceServer) PodLogs 

func (*UnimplementedWorkflowServiceServer) PodLogs(req *WorkflowLogRequest, srv WorkflowService_PodLogsServer) error

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow 

func (*UnimplementedWorkflowServiceServer) ResubmitWorkflow(ctx context.Context, req *WorkflowResubmitRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow 

func (*UnimplementedWorkflowServiceServer) ResumeWorkflow(ctx context.Context, req *WorkflowResumeRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) RetryWorkflow 

func (*UnimplementedWorkflowServiceServer) RetryWorkflow(ctx context.Context, req *WorkflowRetryRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow 

func (*UnimplementedWorkflowServiceServer) SuspendWorkflow(ctx context.Context, req *WorkflowSuspendRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow 

func (*UnimplementedWorkflowServiceServer) TerminateWorkflow(ctx context.Context, req *WorkflowTerminateRequest) (*v1alpha1.Workflow, error)

func (*UnimplementedWorkflowServiceServer) WatchWorkflows 

func (*UnimplementedWorkflowServiceServer) WatchWorkflows(req *WatchWorkflowsRequest, srv WorkflowService_WatchWorkflowsServer) error

type WatchWorkflowsRequest 

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

func (*WatchWorkflowsRequest) Descriptor 

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

func (*WatchWorkflowsRequest) GetListOptions 

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

func (*WatchWorkflowsRequest) GetNamespace 

func (m *WatchWorkflowsRequest) GetNamespace() string

func (*WatchWorkflowsRequest) Marshal 

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

func (*WatchWorkflowsRequest) MarshalTo 

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

func (*WatchWorkflowsRequest) MarshalToSizedBuffer 

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

func (*WatchWorkflowsRequest) ProtoMessage 

func (*WatchWorkflowsRequest) ProtoMessage()

func (*WatchWorkflowsRequest) Reset 

func (m *WatchWorkflowsRequest) Reset()

func (*WatchWorkflowsRequest) Size 

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

func (*WatchWorkflowsRequest) String 

func (m *WatchWorkflowsRequest) String() string

func (*WatchWorkflowsRequest) Unmarshal 

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

func (*WatchWorkflowsRequest) XXX_DiscardUnknown 

func (m *WatchWorkflowsRequest) XXX_DiscardUnknown()

func (*WatchWorkflowsRequest) XXX_Marshal 

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

func (*WatchWorkflowsRequest) XXX_Merge 

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

func (*WatchWorkflowsRequest) XXX_Size 

func (m *WatchWorkflowsRequest) XXX_Size() int

func (*WatchWorkflowsRequest) XXX_Unmarshal 

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

type WorkflowCreateRequest 

type WorkflowCreateRequest struct {
	Namespace            string             `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Workflow             *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	InstanceID           string             `protobuf:"bytes,3,opt,name=instanceID,proto3" json:"instanceID,omitempty"`
	ServerDryRun         bool               `protobuf:"varint,4,opt,name=serverDryRun,proto3" json:"serverDryRun,omitempty"`
	CreateOptions        *v1.CreateOptions  `protobuf:"bytes,5,opt,name=createOptions,proto3" json:"createOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowCreateRequest) Descriptor 

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

func (*WorkflowCreateRequest) GetCreateOptions 

func (m *WorkflowCreateRequest) GetCreateOptions() *v1.CreateOptions

func (*WorkflowCreateRequest) GetInstanceID 

func (m *WorkflowCreateRequest) GetInstanceID() string

func (*WorkflowCreateRequest) GetNamespace 

func (m *WorkflowCreateRequest) GetNamespace() string

func (*WorkflowCreateRequest) GetServerDryRun 

func (m *WorkflowCreateRequest) GetServerDryRun() bool

func (*WorkflowCreateRequest) GetWorkflow 

func (m *WorkflowCreateRequest) GetWorkflow() *v1alpha1.Workflow

func (*WorkflowCreateRequest) Marshal 

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

func (*WorkflowCreateRequest) MarshalTo 

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

func (*WorkflowCreateRequest) MarshalToSizedBuffer 

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

func (*WorkflowCreateRequest) ProtoMessage 

func (*WorkflowCreateRequest) ProtoMessage()

func (*WorkflowCreateRequest) Reset 

func (m *WorkflowCreateRequest) Reset()

func (*WorkflowCreateRequest) Size 

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

func (*WorkflowCreateRequest) String 

func (m *WorkflowCreateRequest) String() string

func (*WorkflowCreateRequest) Unmarshal 

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

func (*WorkflowCreateRequest) XXX_DiscardUnknown 

func (m *WorkflowCreateRequest) XXX_DiscardUnknown()

func (*WorkflowCreateRequest) XXX_Marshal 

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

func (*WorkflowCreateRequest) XXX_Merge 

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

func (*WorkflowCreateRequest) XXX_Size 

func (m *WorkflowCreateRequest) XXX_Size() int

func (*WorkflowCreateRequest) XXX_Unmarshal 

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

type WorkflowDeleteRequest 

type WorkflowDeleteRequest struct {
	Name                 string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string            `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	DeleteOptions        *v1.DeleteOptions `protobuf:"bytes,3,opt,name=deleteOptions,proto3" json:"deleteOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*WorkflowDeleteRequest) Descriptor 

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

func (*WorkflowDeleteRequest) GetDeleteOptions 

func (m *WorkflowDeleteRequest) GetDeleteOptions() *v1.DeleteOptions

func (*WorkflowDeleteRequest) GetName 

func (m *WorkflowDeleteRequest) GetName() string

func (*WorkflowDeleteRequest) GetNamespace 

func (m *WorkflowDeleteRequest) GetNamespace() string

func (*WorkflowDeleteRequest) Marshal 

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

func (*WorkflowDeleteRequest) MarshalTo 

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

func (*WorkflowDeleteRequest) MarshalToSizedBuffer 

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

func (*WorkflowDeleteRequest) ProtoMessage 

func (*WorkflowDeleteRequest) ProtoMessage()

func (*WorkflowDeleteRequest) Reset 

func (m *WorkflowDeleteRequest) Reset()

func (*WorkflowDeleteRequest) Size 

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

func (*WorkflowDeleteRequest) String 

func (m *WorkflowDeleteRequest) String() string

func (*WorkflowDeleteRequest) Unmarshal 

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

func (*WorkflowDeleteRequest) XXX_DiscardUnknown 

func (m *WorkflowDeleteRequest) XXX_DiscardUnknown()

func (*WorkflowDeleteRequest) XXX_Marshal 

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

func (*WorkflowDeleteRequest) XXX_Merge 

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

func (*WorkflowDeleteRequest) XXX_Size 

func (m *WorkflowDeleteRequest) XXX_Size() int

func (*WorkflowDeleteRequest) XXX_Unmarshal 

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

type WorkflowDeleteResponse 

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

func (*WorkflowDeleteResponse) Descriptor 

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

func (*WorkflowDeleteResponse) Marshal 

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

func (*WorkflowDeleteResponse) MarshalTo 

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

func (*WorkflowDeleteResponse) MarshalToSizedBuffer 

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

func (*WorkflowDeleteResponse) ProtoMessage 

func (*WorkflowDeleteResponse) ProtoMessage()

func (*WorkflowDeleteResponse) Reset 

func (m *WorkflowDeleteResponse) Reset()

func (*WorkflowDeleteResponse) Size 

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

func (*WorkflowDeleteResponse) String 

func (m *WorkflowDeleteResponse) String() string

func (*WorkflowDeleteResponse) Unmarshal 

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

func (*WorkflowDeleteResponse) XXX_DiscardUnknown 

func (m *WorkflowDeleteResponse) XXX_DiscardUnknown()

func (*WorkflowDeleteResponse) XXX_Marshal 

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

func (*WorkflowDeleteResponse) XXX_Merge 

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

func (*WorkflowDeleteResponse) XXX_Size 

func (m *WorkflowDeleteResponse) XXX_Size() int

func (*WorkflowDeleteResponse) XXX_Unmarshal 

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

type WorkflowGetRequest 

type WorkflowGetRequest struct {
	Name                 string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string         `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	GetOptions           *v1.GetOptions `protobuf:"bytes,3,opt,name=getOptions,proto3" json:"getOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*WorkflowGetRequest) Descriptor 

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

func (*WorkflowGetRequest) GetGetOptions 

func (m *WorkflowGetRequest) GetGetOptions() *v1.GetOptions

func (*WorkflowGetRequest) GetName 

func (m *WorkflowGetRequest) GetName() string

func (*WorkflowGetRequest) GetNamespace 

func (m *WorkflowGetRequest) GetNamespace() string

func (*WorkflowGetRequest) Marshal 

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

func (*WorkflowGetRequest) MarshalTo 

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

func (*WorkflowGetRequest) MarshalToSizedBuffer 

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

func (*WorkflowGetRequest) ProtoMessage 

func (*WorkflowGetRequest) ProtoMessage()

func (*WorkflowGetRequest) Reset 

func (m *WorkflowGetRequest) Reset()

func (*WorkflowGetRequest) Size 

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

func (*WorkflowGetRequest) String 

func (m *WorkflowGetRequest) String() string

func (*WorkflowGetRequest) Unmarshal 

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

func (*WorkflowGetRequest) XXX_DiscardUnknown 

func (m *WorkflowGetRequest) XXX_DiscardUnknown()

func (*WorkflowGetRequest) XXX_Marshal 

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

func (*WorkflowGetRequest) XXX_Merge 

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

func (*WorkflowGetRequest) XXX_Size 

func (m *WorkflowGetRequest) XXX_Size() int

func (*WorkflowGetRequest) XXX_Unmarshal 

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

type WorkflowLintRequest 

type WorkflowLintRequest struct {
	Namespace            string             `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Workflow             *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowLintRequest) Descriptor 

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

func (*WorkflowLintRequest) GetNamespace 

func (m *WorkflowLintRequest) GetNamespace() string

func (*WorkflowLintRequest) GetWorkflow 

func (m *WorkflowLintRequest) GetWorkflow() *v1alpha1.Workflow

func (*WorkflowLintRequest) Marshal 

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

func (*WorkflowLintRequest) MarshalTo 

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

func (*WorkflowLintRequest) MarshalToSizedBuffer 

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

func (*WorkflowLintRequest) ProtoMessage 

func (*WorkflowLintRequest) ProtoMessage()

func (*WorkflowLintRequest) Reset 

func (m *WorkflowLintRequest) Reset()

func (*WorkflowLintRequest) Size 

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

func (*WorkflowLintRequest) String 

func (m *WorkflowLintRequest) String() string

func (*WorkflowLintRequest) Unmarshal 

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

func (*WorkflowLintRequest) XXX_DiscardUnknown 

func (m *WorkflowLintRequest) XXX_DiscardUnknown()

func (*WorkflowLintRequest) XXX_Marshal 

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

func (*WorkflowLintRequest) XXX_Merge 

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

func (*WorkflowLintRequest) XXX_Size 

func (m *WorkflowLintRequest) XXX_Size() int

func (*WorkflowLintRequest) XXX_Unmarshal 

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

type WorkflowListRequest 

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

func (*WorkflowListRequest) Descriptor 

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

func (*WorkflowListRequest) GetListOptions 

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

func (*WorkflowListRequest) GetNamespace 

func (m *WorkflowListRequest) GetNamespace() string

func (*WorkflowListRequest) Marshal 

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

func (*WorkflowListRequest) MarshalTo 

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

func (*WorkflowListRequest) MarshalToSizedBuffer 

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

func (*WorkflowListRequest) ProtoMessage 

func (*WorkflowListRequest) ProtoMessage()

func (*WorkflowListRequest) Reset 

func (m *WorkflowListRequest) Reset()

func (*WorkflowListRequest) Size 

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

func (*WorkflowListRequest) String 

func (m *WorkflowListRequest) String() string

func (*WorkflowListRequest) Unmarshal 

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

func (*WorkflowListRequest) XXX_DiscardUnknown 

func (m *WorkflowListRequest) XXX_DiscardUnknown()

func (*WorkflowListRequest) XXX_Marshal 

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

func (*WorkflowListRequest) XXX_Merge 

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

func (*WorkflowListRequest) XXX_Size 

func (m *WorkflowListRequest) XXX_Size() int

func (*WorkflowListRequest) XXX_Unmarshal 

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

type WorkflowLogRequest 

type WorkflowLogRequest struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string             `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	PodName              string             `protobuf:"bytes,3,opt,name=podName,proto3" json:"podName,omitempty"`
	LogOptions           *v11.PodLogOptions `protobuf:"bytes,4,opt,name=logOptions,proto3" json:"logOptions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowLogRequest) Descriptor 

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

func (*WorkflowLogRequest) GetLogOptions 

func (m *WorkflowLogRequest) GetLogOptions() *v11.PodLogOptions

func (*WorkflowLogRequest) GetName 

func (m *WorkflowLogRequest) GetName() string

func (*WorkflowLogRequest) GetNamespace 

func (m *WorkflowLogRequest) GetNamespace() string

func (*WorkflowLogRequest) GetPodName 

func (m *WorkflowLogRequest) GetPodName() string

func (*WorkflowLogRequest) Marshal 

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

func (*WorkflowLogRequest) MarshalTo 

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

func (*WorkflowLogRequest) MarshalToSizedBuffer 

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

func (*WorkflowLogRequest) ProtoMessage 

func (*WorkflowLogRequest) ProtoMessage()

func (*WorkflowLogRequest) Reset 

func (m *WorkflowLogRequest) Reset()

func (*WorkflowLogRequest) Size 

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

func (*WorkflowLogRequest) String 

func (m *WorkflowLogRequest) String() string

func (*WorkflowLogRequest) Unmarshal 

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

func (*WorkflowLogRequest) XXX_DiscardUnknown 

func (m *WorkflowLogRequest) XXX_DiscardUnknown()

func (*WorkflowLogRequest) XXX_Marshal 

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

func (*WorkflowLogRequest) XXX_Merge 

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

func (*WorkflowLogRequest) XXX_Size 

func (m *WorkflowLogRequest) XXX_Size() int

func (*WorkflowLogRequest) XXX_Unmarshal 

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

type WorkflowResubmitRequest 

type WorkflowResubmitRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Memoized             bool     `protobuf:"varint,3,opt,name=memoized,proto3" json:"memoized,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowResubmitRequest) Descriptor 

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

func (*WorkflowResubmitRequest) GetMemoized 

func (m *WorkflowResubmitRequest) GetMemoized() bool

func (*WorkflowResubmitRequest) GetName 

func (m *WorkflowResubmitRequest) GetName() string

func (*WorkflowResubmitRequest) GetNamespace 

func (m *WorkflowResubmitRequest) GetNamespace() string

func (*WorkflowResubmitRequest) Marshal 

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

func (*WorkflowResubmitRequest) MarshalTo 

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

func (*WorkflowResubmitRequest) MarshalToSizedBuffer 

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

func (*WorkflowResubmitRequest) ProtoMessage 

func (*WorkflowResubmitRequest) ProtoMessage()

func (*WorkflowResubmitRequest) Reset 

func (m *WorkflowResubmitRequest) Reset()

func (*WorkflowResubmitRequest) Size 

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

func (*WorkflowResubmitRequest) String 

func (m *WorkflowResubmitRequest) String() string

func (*WorkflowResubmitRequest) Unmarshal 

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

func (*WorkflowResubmitRequest) XXX_DiscardUnknown 

func (m *WorkflowResubmitRequest) XXX_DiscardUnknown()

func (*WorkflowResubmitRequest) XXX_Marshal 

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

func (*WorkflowResubmitRequest) XXX_Merge 

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

func (*WorkflowResubmitRequest) XXX_Size 

func (m *WorkflowResubmitRequest) XXX_Size() int

func (*WorkflowResubmitRequest) XXX_Unmarshal 

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

type WorkflowResumeRequest 

type WorkflowResumeRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowResumeRequest) Descriptor 

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

func (*WorkflowResumeRequest) GetName 

func (m *WorkflowResumeRequest) GetName() string

func (*WorkflowResumeRequest) GetNamespace 

func (m *WorkflowResumeRequest) GetNamespace() string

func (*WorkflowResumeRequest) Marshal 

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

func (*WorkflowResumeRequest) MarshalTo 

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

func (*WorkflowResumeRequest) MarshalToSizedBuffer 

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

func (*WorkflowResumeRequest) ProtoMessage 

func (*WorkflowResumeRequest) ProtoMessage()

func (*WorkflowResumeRequest) Reset 

func (m *WorkflowResumeRequest) Reset()

func (*WorkflowResumeRequest) Size 

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

func (*WorkflowResumeRequest) String 

func (m *WorkflowResumeRequest) String() string

func (*WorkflowResumeRequest) Unmarshal 

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

func (*WorkflowResumeRequest) XXX_DiscardUnknown 

func (m *WorkflowResumeRequest) XXX_DiscardUnknown()

func (*WorkflowResumeRequest) XXX_Marshal 

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

func (*WorkflowResumeRequest) XXX_Merge 

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

func (*WorkflowResumeRequest) XXX_Size 

func (m *WorkflowResumeRequest) XXX_Size() int

func (*WorkflowResumeRequest) XXX_Unmarshal 

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

type WorkflowRetryRequest 

type WorkflowRetryRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowRetryRequest) Descriptor 

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

func (*WorkflowRetryRequest) GetName 

func (m *WorkflowRetryRequest) GetName() string

func (*WorkflowRetryRequest) GetNamespace 

func (m *WorkflowRetryRequest) GetNamespace() string

func (*WorkflowRetryRequest) Marshal 

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

func (*WorkflowRetryRequest) MarshalTo 

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

func (*WorkflowRetryRequest) MarshalToSizedBuffer 

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

func (*WorkflowRetryRequest) ProtoMessage 

func (*WorkflowRetryRequest) ProtoMessage()

func (*WorkflowRetryRequest) Reset 

func (m *WorkflowRetryRequest) Reset()

func (*WorkflowRetryRequest) Size 

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

func (*WorkflowRetryRequest) String 

func (m *WorkflowRetryRequest) String() string

func (*WorkflowRetryRequest) Unmarshal 

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

func (*WorkflowRetryRequest) XXX_DiscardUnknown 

func (m *WorkflowRetryRequest) XXX_DiscardUnknown()

func (*WorkflowRetryRequest) XXX_Marshal 

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

func (*WorkflowRetryRequest) XXX_Merge 

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

func (*WorkflowRetryRequest) XXX_Size 

func (m *WorkflowRetryRequest) XXX_Size() int

func (*WorkflowRetryRequest) XXX_Unmarshal 

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

type WorkflowServiceClient 

type WorkflowServiceClient interface {
	CreateWorkflow(ctx context.Context, in *WorkflowCreateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	GetWorkflow(ctx context.Context, in *WorkflowGetRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ListWorkflows(ctx context.Context, in *WorkflowListRequest, opts ...grpc.CallOption) (*v1alpha1.WorkflowList, error)
	WatchWorkflows(ctx context.Context, in *WatchWorkflowsRequest, opts ...grpc.CallOption) (WorkflowService_WatchWorkflowsClient, error)
	DeleteWorkflow(ctx context.Context, in *WorkflowDeleteRequest, opts ...grpc.CallOption) (*WorkflowDeleteResponse, error)
	RetryWorkflow(ctx context.Context, in *WorkflowRetryRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ResubmitWorkflow(ctx context.Context, in *WorkflowResubmitRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	ResumeWorkflow(ctx context.Context, in *WorkflowResumeRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	SuspendWorkflow(ctx context.Context, in *WorkflowSuspendRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	TerminateWorkflow(ctx context.Context, in *WorkflowTerminateRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	LintWorkflow(ctx context.Context, in *WorkflowLintRequest, opts ...grpc.CallOption) (*v1alpha1.Workflow, error)
	PodLogs(ctx context.Context, in *WorkflowLogRequest, opts ...grpc.CallOption) (WorkflowService_PodLogsClient, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

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

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc *grpc.ClientConn) WorkflowServiceClient

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	CreateWorkflow(context.Context, *WorkflowCreateRequest) (*v1alpha1.Workflow, error)
	GetWorkflow(context.Context, *WorkflowGetRequest) (*v1alpha1.Workflow, error)
	ListWorkflows(context.Context, *WorkflowListRequest) (*v1alpha1.WorkflowList, error)
	WatchWorkflows(*WatchWorkflowsRequest, WorkflowService_WatchWorkflowsServer) error
	DeleteWorkflow(context.Context, *WorkflowDeleteRequest) (*WorkflowDeleteResponse, error)
	RetryWorkflow(context.Context, *WorkflowRetryRequest) (*v1alpha1.Workflow, error)
	ResubmitWorkflow(context.Context, *WorkflowResubmitRequest) (*v1alpha1.Workflow, error)
	ResumeWorkflow(context.Context, *WorkflowResumeRequest) (*v1alpha1.Workflow, error)
	SuspendWorkflow(context.Context, *WorkflowSuspendRequest) (*v1alpha1.Workflow, error)
	TerminateWorkflow(context.Context, *WorkflowTerminateRequest) (*v1alpha1.Workflow, error)
	LintWorkflow(context.Context, *WorkflowLintRequest) (*v1alpha1.Workflow, error)
	PodLogs(*WorkflowLogRequest, WorkflowService_PodLogsServer) error
}

WorkflowServiceServer is the server API for WorkflowService service.

type WorkflowService_PodLogsClient 

type WorkflowService_PodLogsClient interface {
	Recv() (*LogEntry, error)
	grpc.ClientStream
}

type WorkflowService_PodLogsServer 

type WorkflowService_PodLogsServer interface {
	Send(*LogEntry) error
	grpc.ServerStream
}

type WorkflowService_WatchWorkflowsClient 

type WorkflowService_WatchWorkflowsClient interface {
	Recv() (*WorkflowWatchEvent, error)
	grpc.ClientStream
}

type WorkflowService_WatchWorkflowsServer 

type WorkflowService_WatchWorkflowsServer interface {
	Send(*WorkflowWatchEvent) error
	grpc.ServerStream
}

type WorkflowSuspendRequest 

type WorkflowSuspendRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowSuspendRequest) Descriptor 

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

func (*WorkflowSuspendRequest) GetName 

func (m *WorkflowSuspendRequest) GetName() string

func (*WorkflowSuspendRequest) GetNamespace 

func (m *WorkflowSuspendRequest) GetNamespace() string

func (*WorkflowSuspendRequest) Marshal 

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

func (*WorkflowSuspendRequest) MarshalTo 

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

func (*WorkflowSuspendRequest) MarshalToSizedBuffer 

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

func (*WorkflowSuspendRequest) ProtoMessage 

func (*WorkflowSuspendRequest) ProtoMessage()

func (*WorkflowSuspendRequest) Reset 

func (m *WorkflowSuspendRequest) Reset()

func (*WorkflowSuspendRequest) Size 

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

func (*WorkflowSuspendRequest) String 

func (m *WorkflowSuspendRequest) String() string

func (*WorkflowSuspendRequest) Unmarshal 

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

func (*WorkflowSuspendRequest) XXX_DiscardUnknown 

func (m *WorkflowSuspendRequest) XXX_DiscardUnknown()

func (*WorkflowSuspendRequest) XXX_Marshal 

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

func (*WorkflowSuspendRequest) XXX_Merge 

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

func (*WorkflowSuspendRequest) XXX_Size 

func (m *WorkflowSuspendRequest) XXX_Size() int

func (*WorkflowSuspendRequest) XXX_Unmarshal 

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

type WorkflowTerminateRequest 

type WorkflowTerminateRequest struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WorkflowTerminateRequest) Descriptor 

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

func (*WorkflowTerminateRequest) GetName 

func (m *WorkflowTerminateRequest) GetName() string

func (*WorkflowTerminateRequest) GetNamespace 

func (m *WorkflowTerminateRequest) GetNamespace() string

func (*WorkflowTerminateRequest) Marshal 

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

func (*WorkflowTerminateRequest) MarshalTo 

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

func (*WorkflowTerminateRequest) MarshalToSizedBuffer 

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

func (*WorkflowTerminateRequest) ProtoMessage 

func (*WorkflowTerminateRequest) ProtoMessage()

func (*WorkflowTerminateRequest) Reset 

func (m *WorkflowTerminateRequest) Reset()

func (*WorkflowTerminateRequest) Size 

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

func (*WorkflowTerminateRequest) String 

func (m *WorkflowTerminateRequest) String() string

func (*WorkflowTerminateRequest) Unmarshal 

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

func (*WorkflowTerminateRequest) XXX_DiscardUnknown 

func (m *WorkflowTerminateRequest) XXX_DiscardUnknown()

func (*WorkflowTerminateRequest) XXX_Marshal 

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

func (*WorkflowTerminateRequest) XXX_Merge 

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

func (*WorkflowTerminateRequest) XXX_Size 

func (m *WorkflowTerminateRequest) XXX_Size() int

func (*WorkflowTerminateRequest) XXX_Unmarshal 

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

type WorkflowWatchEvent 

type WorkflowWatchEvent struct {
	// the type of change
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// the workflow
	Object               *v1alpha1.Workflow `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*WorkflowWatchEvent) Descriptor 

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

func (*WorkflowWatchEvent) GetObject 

func (m *WorkflowWatchEvent) GetObject() *v1alpha1.Workflow

func (*WorkflowWatchEvent) GetType 

func (m *WorkflowWatchEvent) GetType() string

func (*WorkflowWatchEvent) Marshal 

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

func (*WorkflowWatchEvent) MarshalTo 

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

func (*WorkflowWatchEvent) MarshalToSizedBuffer 

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

func (*WorkflowWatchEvent) ProtoMessage 

func (*WorkflowWatchEvent) ProtoMessage()

func (*WorkflowWatchEvent) Reset 

func (m *WorkflowWatchEvent) Reset()

func (*WorkflowWatchEvent) Size 

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

func (*WorkflowWatchEvent) String 

func (m *WorkflowWatchEvent) String() string

func (*WorkflowWatchEvent) Unmarshal 

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

func (*WorkflowWatchEvent) XXX_DiscardUnknown 

func (m *WorkflowWatchEvent) XXX_DiscardUnknown()

func (*WorkflowWatchEvent) XXX_Marshal 

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

func (*WorkflowWatchEvent) XXX_Merge 

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

func (*WorkflowWatchEvent) XXX_Size 

func (m *WorkflowWatchEvent) XXX_Size() int

func (*WorkflowWatchEvent) XXX_Unmarshal 

func (m *WorkflowWatchEvent) XXX_Unmarshal(b []byte) 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.