go_client

package
v2.0.0-...-6fac617 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Predicate_Op_name = map[int32]string{
		0: "UNKNOWN",
		1: "EQUALS",
		2: "NOT_EQUALS",
		3: "GREATER_THAN",
		5: "GREATER_THAN_EQUALS",
		6: "LESS_THAN",
		7: "LESS_THAN_EQUALS",
		8: "IN",
		9: "IS_SUBSTRING",
	}
	Predicate_Op_value = map[string]int32{
		"UNKNOWN":             0,
		"EQUALS":              1,
		"NOT_EQUALS":          2,
		"GREATER_THAN":        3,
		"GREATER_THAN_EQUALS": 5,
		"LESS_THAN":           6,
		"LESS_THAN_EQUALS":    7,
		"IN":                  8,
		"IS_SUBSTRING":        9,
	}
)

Enum value maps for Predicate_Op.

View Source 
var (
	ResourceType_name = map[int32]string{
		0: "UNKNOWN_RESOURCE_TYPE",
		1: "EXPERIMENT",
		2: "JOB",
		3: "PIPELINE",
		4: "PIPELINE_VERSION",
		5: "NAMESPACE",
	}
	ResourceType_value = map[string]int32{
		"UNKNOWN_RESOURCE_TYPE": 0,
		"EXPERIMENT":            1,
		"JOB":                   2,
		"PIPELINE":              3,
		"PIPELINE_VERSION":      4,
		"NAMESPACE":             5,
	}
)

Enum value maps for ResourceType.

View Source 
var (
	Relationship_name = map[int32]string{
		0: "UNKNOWN_RELATIONSHIP",
		1: "OWNER",
		2: "CREATOR",
	}
	Relationship_value = map[string]int32{
		"UNKNOWN_RELATIONSHIP": 0,
		"OWNER":                1,
		"CREATOR":              2,
	}
)

Enum value maps for Relationship.

View Source 
var File_backend_api_filter_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_resource_reference_proto protoreflect.FileDescriptor
View Source 
var File_backend_api_task_proto protoreflect.FileDescriptor

Functions

func RegisterDummyFilterServiceServer 

func RegisterDummyFilterServiceServer(s *grpc.Server, srv DummyFilterServiceServer)

func RegisterTaskServiceServer 

func RegisterTaskServiceServer(s *grpc.Server, srv TaskServiceServer)

Types

type CreateTaskRequest 

type CreateTaskRequest struct {
	Task *Task `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated 

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

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetTask 

func (x *CreateTaskRequest) GetTask() *Task

func (*CreateTaskRequest) ProtoMessage 

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect 

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

func (*CreateTaskRequest) Reset 

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String 

func (x *CreateTaskRequest) String() string

type DummyFilterServiceClient 

type DummyFilterServiceClient interface {
	GetFilter(ctx context.Context, in *Filter, opts ...grpc.CallOption) (*Filter, error)
}

DummyFilterServiceClient is the client API for DummyFilterService service.

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

func NewDummyFilterServiceClient 

func NewDummyFilterServiceClient(cc grpc.ClientConnInterface) DummyFilterServiceClient

type DummyFilterServiceServer 

type DummyFilterServiceServer interface {
	GetFilter(context.Context, *Filter) (*Filter, error)
}

DummyFilterServiceServer is the server API for DummyFilterService service.

type Filter 

type Filter struct {

	// All predicates are AND-ed when this filter is applied.
	Predicates []*Predicate `protobuf:"bytes,1,rep,name=predicates,proto3" json:"predicates,omitempty"`
	// contains filtered or unexported fields
}

Filter is used to filter resources returned from a ListXXX request.

Example filters: 1) Filter runs with status = 'Running' 

filter {
  predicate {
    key: "status"
    op: EQUALS
    string_value: "Running"
  }
}

2) Filter runs that succeeded since Dec 1, 2018 

filter {
  predicate {
    key: "status"
    op: EQUALS
    string_value: "Succeeded"
  }
  predicate {
    key: "created_at"
    op: GREATER_THAN
    timestamp_value {
      seconds: 1543651200
    }
  }
}

3) Filter runs with one of labels 'label_1' or 'label_2' 

filter {
  predicate {
    key: "label"
    op: IN
    string_values {
      value: 'label_1'
      value: 'label_2'
    }
  }
}

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) GetPredicates 

func (x *Filter) GetPredicates() []*Predicate

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) String 

func (x *Filter) String() string

type IntValues 

type IntValues struct {
	Values []int32 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*IntValues) Descriptor deprecated 

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

Deprecated: Use IntValues.ProtoReflect.Descriptor instead.

func (*IntValues) GetValues 

func (x *IntValues) GetValues() []int32

func (*IntValues) ProtoMessage 

func (*IntValues) ProtoMessage()

func (*IntValues) ProtoReflect 

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

func (*IntValues) Reset 

func (x *IntValues) Reset()

func (*IntValues) String 

func (x *IntValues) String() string

type ListTasksRequest 

type ListTasksRequest struct {

	// A page token to request the next page of results. The token is acquried
	// from the nextPageToken field of the response from the previous
	// ListExperiment call or can be omitted when fetching the first page.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// The number of experiments to be listed per page. If there are more
	// experiments than this number, the response message will contain a
	// nextPageToken field you can use to fetch the next page.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Can be format of "field_name", "field_name asc" or "field_name desc"
	// Ascending by default.
	SortBy string `protobuf:"bytes,3,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
	// What resource reference to filter on.
	// E.g. If listing tasks for an pipeline run, the query string would be
	// resource_reference_key.type="PIPELINE"&resource_reference_key.id=123
	ResourceReferenceKey *ResourceKey `protobuf:"bytes,4,opt,name=resource_reference_key,json=resourceReferenceKey,proto3" json:"resource_reference_key,omitempty"`
	// A url-encoded, JSON-serialized Filter protocol buffer (see
	// [filter.proto](https://github.com/kubeflow/pipelines/
	// blob/master/backend/api/filter.proto)).
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksRequest) Descriptor deprecated 

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

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) GetFilter 

func (x *ListTasksRequest) GetFilter() string

func (*ListTasksRequest) GetPageSize 

func (x *ListTasksRequest) GetPageSize() int32

func (*ListTasksRequest) GetPageToken 

func (x *ListTasksRequest) GetPageToken() string

func (*ListTasksRequest) GetResourceReferenceKey 

func (x *ListTasksRequest) GetResourceReferenceKey() *ResourceKey

func (*ListTasksRequest) GetSortBy 

func (x *ListTasksRequest) GetSortBy() string

func (*ListTasksRequest) ProtoMessage 

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect 

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

func (*ListTasksRequest) Reset 

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String 

func (x *ListTasksRequest) String() string

type ListTasksResponse 

type ListTasksResponse struct {

	// A list of tasks returned.
	Tasks []*Task `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// The token to list the next page of experiments.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// The total number of experiments for the given query.
	TotalSize int32 `protobuf:"varint,3,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated 

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

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetNextPageToken 

func (x *ListTasksResponse) GetNextPageToken() string

func (*ListTasksResponse) GetTasks 

func (x *ListTasksResponse) GetTasks() []*Task

func (*ListTasksResponse) GetTotalSize 

func (x *ListTasksResponse) GetTotalSize() int32

func (*ListTasksResponse) ProtoMessage 

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect 

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

func (*ListTasksResponse) Reset 

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String 

func (x *ListTasksResponse) String() string

type LongValues 

type LongValues struct {
	Values []int64 `protobuf:"varint,3,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*LongValues) Descriptor deprecated 

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

Deprecated: Use LongValues.ProtoReflect.Descriptor instead.

func (*LongValues) GetValues 

func (x *LongValues) GetValues() []int64

func (*LongValues) ProtoMessage 

func (*LongValues) ProtoMessage()

func (*LongValues) ProtoReflect 

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

func (*LongValues) Reset 

func (x *LongValues) Reset()

func (*LongValues) String 

func (x *LongValues) String() string

type Predicate 

type Predicate struct {
	Op  Predicate_Op `protobuf:"varint,1,opt,name=op,proto3,enum=api.Predicate_Op" json:"op,omitempty"`
	Key string       `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Value:
	//	*Predicate_IntValue
	//	*Predicate_LongValue
	//	*Predicate_StringValue
	//	*Predicate_TimestampValue
	//	*Predicate_IntValues
	//	*Predicate_LongValues
	//	*Predicate_StringValues
	Value isPredicate_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Predicate captures individual conditions that must be true for a resource being filtered.

func (*Predicate) Descriptor deprecated 

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

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) GetIntValue 

func (x *Predicate) GetIntValue() int32

func (*Predicate) GetIntValues 

func (x *Predicate) GetIntValues() *IntValues

func (*Predicate) GetKey 

func (x *Predicate) GetKey() string

func (*Predicate) GetLongValue 

func (x *Predicate) GetLongValue() int64

func (*Predicate) GetLongValues 

func (x *Predicate) GetLongValues() *LongValues

func (*Predicate) GetOp 

func (x *Predicate) GetOp() Predicate_Op

func (*Predicate) GetStringValue 

func (x *Predicate) GetStringValue() string

func (*Predicate) GetStringValues 

func (x *Predicate) GetStringValues() *StringValues

func (*Predicate) GetTimestampValue 

func (x *Predicate) GetTimestampValue() *timestamppb.Timestamp

func (*Predicate) GetValue 

func (m *Predicate) GetValue() isPredicate_Value

func (*Predicate) ProtoMessage 

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect 

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

func (*Predicate) Reset 

func (x *Predicate) Reset()

func (*Predicate) String 

func (x *Predicate) String() string

type Predicate_IntValue 

type Predicate_IntValue struct {
	IntValue int32 `protobuf:"varint,3,opt,name=int_value,json=intValue,proto3,oneof"`
}

type Predicate_IntValues 

type Predicate_IntValues struct {
	// Array values below are only meant to be used by the IN operator.
	IntValues *IntValues `protobuf:"bytes,7,opt,name=int_values,json=intValues,proto3,oneof"`
}

type Predicate_LongValue 

type Predicate_LongValue struct {
	LongValue int64 `protobuf:"varint,4,opt,name=long_value,json=longValue,proto3,oneof"`
}

type Predicate_LongValues 

type Predicate_LongValues struct {
	LongValues *LongValues `protobuf:"bytes,8,opt,name=long_values,json=longValues,proto3,oneof"`
}

type Predicate_Op 

type Predicate_Op int32

Op is the operation to apply. 

const (
	Predicate_UNKNOWN Predicate_Op = 0
	// Operators on scalar values. Only applies to one of |int_value|,
	// |long_value|, |string_value| or |timestamp_value|.
	Predicate_EQUALS              Predicate_Op = 1
	Predicate_NOT_EQUALS          Predicate_Op = 2
	Predicate_GREATER_THAN        Predicate_Op = 3
	Predicate_GREATER_THAN_EQUALS Predicate_Op = 5
	Predicate_LESS_THAN           Predicate_Op = 6
	Predicate_LESS_THAN_EQUALS    Predicate_Op = 7
	// Checks if the value is a member of a given array, which should be one of
	// |int_values|, |long_values| or |string_values|.
	Predicate_IN Predicate_Op = 8
	// Checks if the value contains |string_value| as a substring match. Only
	// applies to |string_value|.
	Predicate_IS_SUBSTRING Predicate_Op = 9
)

func (Predicate_Op) Descriptor 

func (Predicate_Op) Descriptor() protoreflect.EnumDescriptor

func (Predicate_Op) Enum 

func (x Predicate_Op) Enum() *Predicate_Op

func (Predicate_Op) EnumDescriptor deprecated 

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

Deprecated: Use Predicate_Op.Descriptor instead.

func (Predicate_Op) Number 

func (x Predicate_Op) Number() protoreflect.EnumNumber

func (Predicate_Op) String 

func (x Predicate_Op) String() string

func (Predicate_Op) Type 

func (Predicate_Op) Type() protoreflect.EnumType

type Predicate_StringValue 

type Predicate_StringValue struct {
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof"`
}

type Predicate_StringValues 

type Predicate_StringValues struct {
	StringValues *StringValues `protobuf:"bytes,9,opt,name=string_values,json=stringValues,proto3,oneof"`
}

type Predicate_TimestampValue 

type Predicate_TimestampValue struct {
	// Timestamp values will be converted to Unix time (seconds since the epoch)
	// prior to being used in a filtering operation.
	TimestampValue *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=timestamp_value,json=timestampValue,proto3,oneof"`
}

type Relationship 

type Relationship int32
const (
	Relationship_UNKNOWN_RELATIONSHIP Relationship = 0
	Relationship_OWNER                Relationship = 1
	Relationship_CREATOR              Relationship = 2
)

func (Relationship) Descriptor 

func (Relationship) Descriptor() protoreflect.EnumDescriptor

func (Relationship) Enum 

func (x Relationship) Enum() *Relationship

func (Relationship) EnumDescriptor deprecated 

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

Deprecated: Use Relationship.Descriptor instead.

func (Relationship) Number 

func (x Relationship) Number() protoreflect.EnumNumber

func (Relationship) String 

func (x Relationship) String() string

func (Relationship) Type 

func (Relationship) Type() protoreflect.EnumType

type ResourceKey 

type ResourceKey struct {

	// The type of the resource that referred to.
	Type ResourceType `protobuf:"varint,1,opt,name=type,proto3,enum=api.ResourceType" json:"type,omitempty"`
	// The ID of the resource that referred to.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceKey) Descriptor deprecated 

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

Deprecated: Use ResourceKey.ProtoReflect.Descriptor instead.

func (*ResourceKey) GetId 

func (x *ResourceKey) GetId() string

func (*ResourceKey) GetType 

func (x *ResourceKey) GetType() ResourceType

func (*ResourceKey) ProtoMessage 

func (*ResourceKey) ProtoMessage()

func (*ResourceKey) ProtoReflect 

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

func (*ResourceKey) Reset 

func (x *ResourceKey) Reset()

func (*ResourceKey) String 

func (x *ResourceKey) String() string

type ResourceReference 

type ResourceReference struct {
	Key *ResourceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// The name of the resource that referred to.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Required field. The relationship from referred resource to the object.
	Relationship Relationship `protobuf:"varint,2,opt,name=relationship,proto3,enum=api.Relationship" json:"relationship,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceReference) Descriptor deprecated 

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

Deprecated: Use ResourceReference.ProtoReflect.Descriptor instead.

func (*ResourceReference) GetKey 

func (x *ResourceReference) GetKey() *ResourceKey

func (*ResourceReference) GetName 

func (x *ResourceReference) GetName() string

func (*ResourceReference) GetRelationship 

func (x *ResourceReference) GetRelationship() Relationship

func (*ResourceReference) ProtoMessage 

func (*ResourceReference) ProtoMessage()

func (*ResourceReference) ProtoReflect 

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

func (*ResourceReference) Reset 

func (x *ResourceReference) Reset()

func (*ResourceReference) String 

func (x *ResourceReference) String() string

type ResourceType 

type ResourceType int32
const (
	ResourceType_UNKNOWN_RESOURCE_TYPE ResourceType = 0
	ResourceType_EXPERIMENT            ResourceType = 1
	ResourceType_JOB                   ResourceType = 2
	ResourceType_PIPELINE              ResourceType = 3
	ResourceType_PIPELINE_VERSION      ResourceType = 4
	ResourceType_NAMESPACE             ResourceType = 5
)

func (ResourceType) Descriptor 

func (ResourceType) Descriptor() protoreflect.EnumDescriptor

func (ResourceType) Enum 

func (x ResourceType) Enum() *ResourceType

func (ResourceType) EnumDescriptor deprecated 

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

Deprecated: Use ResourceType.Descriptor instead.

func (ResourceType) Number 

func (x ResourceType) Number() protoreflect.EnumNumber

func (ResourceType) String 

func (x ResourceType) String() string

func (ResourceType) Type 

func (ResourceType) Type() protoreflect.EnumType

type StringValues 

type StringValues struct {
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringValues) Descriptor deprecated 

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

Deprecated: Use StringValues.ProtoReflect.Descriptor instead.

func (*StringValues) GetValues 

func (x *StringValues) GetValues() []string

func (*StringValues) ProtoMessage 

func (*StringValues) ProtoMessage()

func (*StringValues) ProtoReflect 

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

func (*StringValues) Reset 

func (x *StringValues) Reset()

func (*StringValues) String 

func (x *StringValues) String() string

type Task 

type Task struct {

	// Output. Unique task ID. Generated by API server.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Required input field. The Namespace to which this pipeline task belongs.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// Required input field. The PipelineName to which this pipeline task belongs.
	// Namespace will be encoded in the PipelineName.
	// "namespace/${namespace}/pipeline/${pipelineName}" for namespaced pipelines
	// "pipeline/${pipelineName}" for shared pipelines
	PipelineName string `protobuf:"bytes,3,opt,name=pipelineName,proto3" json:"pipelineName,omitempty"`
	// Required input field.The ID of the PipelineRun that the PipelineTask belongs to.
	RunId string `protobuf:"bytes,4,opt,name=runId,proto3" json:"runId,omitempty"`
	// Required input field. The ID of the MLMD execution associated with the PipelineTask.
	MlmdExecutionID string `protobuf:"bytes,5,opt,name=mlmdExecutionID,proto3" json:"mlmdExecutionID,omitempty"`
	// Required input field. The time this task is created.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Optional input field. The time this task is finished.
	FinishedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// Required input field.
	Fingerprint string `protobuf:"bytes,8,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetFingerprint 

func (x *Task) GetFingerprint() string

func (*Task) GetFinishedAt 

func (x *Task) GetFinishedAt() *timestamppb.Timestamp

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetMlmdExecutionID 

func (x *Task) GetMlmdExecutionID() string

func (*Task) GetNamespace 

func (x *Task) GetNamespace() string

func (*Task) GetPipelineName 

func (x *Task) GetPipelineName() string

func (*Task) GetRunId 

func (x *Task) GetRunId() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) String() string

type TaskServiceClient 

type TaskServiceClient interface {
	// Creates a new task.
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*Task, error)
	// Finds all tasks. Supports pagination, and sorting on certain fields.
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
}

TaskServiceClient is the client API for TaskService service.

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

func NewTaskServiceClient 

func NewTaskServiceClient(cc grpc.ClientConnInterface) TaskServiceClient

type TaskServiceServer 

type TaskServiceServer interface {
	// Creates a new task.
	CreateTask(context.Context, *CreateTaskRequest) (*Task, error)
	// Finds all tasks. Supports pagination, and sorting on certain fields.
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
}

TaskServiceServer is the server API for TaskService service.

type UnimplementedDummyFilterServiceServer 

type UnimplementedDummyFilterServiceServer struct {
}

UnimplementedDummyFilterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDummyFilterServiceServer) GetFilter 

func (*UnimplementedDummyFilterServiceServer) GetFilter(context.Context, *Filter) (*Filter, error)

type UnimplementedTaskServiceServer 

type UnimplementedTaskServiceServer struct {
}

UnimplementedTaskServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedTaskServiceServer) CreateTask 

func (*UnimplementedTaskServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*Task, error)

func (*UnimplementedTaskServiceServer) ListTasks 

func (*UnimplementedTaskServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, 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.