results_go_proto

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Mar 2, 2023 License: Apache-2.0 Imports: 19 Imported by: 3

Documentation

Overview

Package results_go_proto is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	RecordSummary_Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "SUCCESS",
		2: "FAILURE",
		3: "TIMEOUT",
		4: "CANCELLED",
	}
	RecordSummary_Status_value = map[string]int32{
		"UNKNOWN":   0,
		"SUCCESS":   1,
		"FAILURE":   2,
		"TIMEOUT":   3,
		"CANCELLED": 4,
	}
)

Enum value maps for RecordSummary_Status.

View Source 
var File_api_proto protoreflect.FileDescriptor
View Source 
var File_resources_proto protoreflect.FileDescriptor
View Source 
var Logs_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tekton.results.v1alpha2.Logs",
	HandlerType: (*LogsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListLogs",
			Handler:    _Logs_ListLogs_Handler,
		},
		{
			MethodName: "DeleteLog",
			Handler:    _Logs_DeleteLog_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetLog",
			Handler:       _Logs_GetLog_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "UpdateLog",
			Handler:       _Logs_UpdateLog_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "api.proto",
}

Logs_ServiceDesc is the grpc.ServiceDesc for Logs 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 Results_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tekton.results.v1alpha2.Results",
	HandlerType: (*ResultsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateResult",
			Handler:    _Results_CreateResult_Handler,
		},
		{
			MethodName: "UpdateResult",
			Handler:    _Results_UpdateResult_Handler,
		},
		{
			MethodName: "GetResult",
			Handler:    _Results_GetResult_Handler,
		},
		{
			MethodName: "DeleteResult",
			Handler:    _Results_DeleteResult_Handler,
		},
		{
			MethodName: "ListResults",
			Handler:    _Results_ListResults_Handler,
		},
		{
			MethodName: "CreateRecord",
			Handler:    _Results_CreateRecord_Handler,
		},
		{
			MethodName: "UpdateRecord",
			Handler:    _Results_UpdateRecord_Handler,
		},
		{
			MethodName: "GetRecord",
			Handler:    _Results_GetRecord_Handler,
		},
		{
			MethodName: "ListRecords",
			Handler:    _Results_ListRecords_Handler,
		},
		{
			MethodName: "DeleteRecord",
			Handler:    _Results_DeleteRecord_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

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

Functions

func RegisterLogsHandler added in v0.5.0 

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

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

func RegisterLogsHandlerClient added in v0.5.0 

func RegisterLogsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client LogsClient) error

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

func RegisterLogsHandlerFromEndpoint added in v0.5.0 

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

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

func RegisterLogsHandlerServer added in v0.5.0 

func RegisterLogsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server LogsServer) error

RegisterLogsHandlerServer registers the http handlers for service Logs to "mux". UnaryRPC :call LogsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterLogsHandlerFromEndpoint instead.

func RegisterLogsServer added in v0.5.0 

func RegisterLogsServer(s grpc.ServiceRegistrar, srv LogsServer)

func RegisterResultsHandler added in v0.5.0 

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

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

func RegisterResultsHandlerClient added in v0.5.0 

func RegisterResultsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ResultsClient) error

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

func RegisterResultsHandlerFromEndpoint added in v0.5.0 

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

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

func RegisterResultsHandlerServer added in v0.5.0 

func RegisterResultsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ResultsServer) error

RegisterResultsHandlerServer registers the http handlers for service Results to "mux". UnaryRPC :call ResultsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterResultsHandlerFromEndpoint instead.

func RegisterResultsServer 

func RegisterResultsServer(s grpc.ServiceRegistrar, srv ResultsServer)

Types

type Any added in v0.3.0 

type Any struct {

	// Unique identifier of the data type stored in value.
	// This is used as a type hint to determine how to unmarshal value.
	// Limited to 128 characters.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// JSON-encoded data.
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

Any represents loosely typed data to be stored within a Record.

func (*Any) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use Any.ProtoReflect.Descriptor instead.

func (*Any) GetType added in v0.3.0 

func (x *Any) GetType() string

func (*Any) GetValue added in v0.3.0 

func (x *Any) GetValue() []byte

func (*Any) ProtoMessage added in v0.3.0 

func (*Any) ProtoMessage()

func (*Any) ProtoReflect added in v0.3.0 

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

func (*Any) Reset added in v0.3.0 

func (x *Any) Reset()

func (*Any) String added in v0.3.0 

func (x *Any) String() string

type CreateRecordRequest 

type CreateRecordRequest struct {

	// User provided parent to partition results under.
	Parent string  `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Record *Record `protobuf:"bytes,2,opt,name=record,proto3" json:"record,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateRecordRequest) Descriptor deprecated 

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

Deprecated: Use CreateRecordRequest.ProtoReflect.Descriptor instead.

func (*CreateRecordRequest) GetParent 

func (x *CreateRecordRequest) GetParent() string

func (*CreateRecordRequest) GetRecord 

func (x *CreateRecordRequest) GetRecord() *Record

func (*CreateRecordRequest) ProtoMessage 

func (*CreateRecordRequest) ProtoMessage()

func (*CreateRecordRequest) ProtoReflect 

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

func (*CreateRecordRequest) Reset 

func (x *CreateRecordRequest) Reset()

func (*CreateRecordRequest) String 

func (x *CreateRecordRequest) String() string

type CreateResultRequest 

type CreateResultRequest struct {

	// User provided parent to partition results under.
	Parent string  `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Result *Result `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResultRequest) Descriptor deprecated 

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

Deprecated: Use CreateResultRequest.ProtoReflect.Descriptor instead.

func (*CreateResultRequest) GetParent 

func (x *CreateResultRequest) GetParent() string

func (*CreateResultRequest) GetResult 

func (x *CreateResultRequest) GetResult() *Result

func (*CreateResultRequest) ProtoMessage 

func (*CreateResultRequest) ProtoMessage()

func (*CreateResultRequest) ProtoReflect 

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

func (*CreateResultRequest) Reset 

func (x *CreateResultRequest) Reset()

func (*CreateResultRequest) String 

func (x *CreateResultRequest) String() string

type DeleteLogRequest added in v0.5.0 

type DeleteLogRequest struct {

	// Name of the log resource to delete
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLogRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use DeleteLogRequest.ProtoReflect.Descriptor instead.

func (*DeleteLogRequest) GetName added in v0.5.0 

func (x *DeleteLogRequest) GetName() string

func (*DeleteLogRequest) ProtoMessage added in v0.5.0 

func (*DeleteLogRequest) ProtoMessage()

func (*DeleteLogRequest) ProtoReflect added in v0.5.0 

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

func (*DeleteLogRequest) Reset added in v0.5.0 

func (x *DeleteLogRequest) Reset()

func (*DeleteLogRequest) String added in v0.5.0 

func (x *DeleteLogRequest) String() string

type DeleteRecordRequest 

type DeleteRecordRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRecordRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRecordRequest.ProtoReflect.Descriptor instead.

func (*DeleteRecordRequest) GetName 

func (x *DeleteRecordRequest) GetName() string

func (*DeleteRecordRequest) ProtoMessage 

func (*DeleteRecordRequest) ProtoMessage()

func (*DeleteRecordRequest) ProtoReflect 

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

func (*DeleteRecordRequest) Reset 

func (x *DeleteRecordRequest) Reset()

func (*DeleteRecordRequest) String 

func (x *DeleteRecordRequest) String() string

type DeleteResultRequest 

type DeleteResultRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteResultRequest) Descriptor deprecated 

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

Deprecated: Use DeleteResultRequest.ProtoReflect.Descriptor instead.

func (*DeleteResultRequest) GetName 

func (x *DeleteResultRequest) GetName() string

func (*DeleteResultRequest) ProtoMessage 

func (*DeleteResultRequest) ProtoMessage()

func (*DeleteResultRequest) ProtoReflect 

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

func (*DeleteResultRequest) Reset 

func (x *DeleteResultRequest) Reset()

func (*DeleteResultRequest) String 

func (x *DeleteResultRequest) String() string

type GetLogRequest added in v0.5.0 

type GetLogRequest struct {

	// Name of the log resource to stream
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogRequest) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use GetLogRequest.ProtoReflect.Descriptor instead.

func (*GetLogRequest) GetName added in v0.5.0 

func (x *GetLogRequest) GetName() string

func (*GetLogRequest) ProtoMessage added in v0.5.0 

func (*GetLogRequest) ProtoMessage()

func (*GetLogRequest) ProtoReflect added in v0.5.0 

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

func (*GetLogRequest) Reset added in v0.5.0 

func (x *GetLogRequest) Reset()

func (*GetLogRequest) String added in v0.5.0 

func (x *GetLogRequest) String() string

type GetRecordRequest 

type GetRecordRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRecordRequest) Descriptor deprecated 

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

Deprecated: Use GetRecordRequest.ProtoReflect.Descriptor instead.

func (*GetRecordRequest) GetName 

func (x *GetRecordRequest) GetName() string

func (*GetRecordRequest) ProtoMessage 

func (*GetRecordRequest) ProtoMessage()

func (*GetRecordRequest) ProtoReflect 

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

func (*GetRecordRequest) Reset 

func (x *GetRecordRequest) Reset()

func (*GetRecordRequest) String 

func (x *GetRecordRequest) String() string

type GetResultRequest 

type GetResultRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResultRequest) Descriptor deprecated 

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

Deprecated: Use GetResultRequest.ProtoReflect.Descriptor instead.

func (*GetResultRequest) GetName 

func (x *GetResultRequest) GetName() string

func (*GetResultRequest) ProtoMessage 

func (*GetResultRequest) ProtoMessage()

func (*GetResultRequest) ProtoReflect 

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

func (*GetResultRequest) Reset 

func (x *GetResultRequest) Reset()

func (*GetResultRequest) String 

func (x *GetResultRequest) String() string

type ListRecordsRequest 

type ListRecordsRequest struct {
	Parent    string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Filter    string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize  int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	OrderBy   string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRecordsRequest) Descriptor deprecated 

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

Deprecated: Use ListRecordsRequest.ProtoReflect.Descriptor instead.

func (*ListRecordsRequest) GetFilter 

func (x *ListRecordsRequest) GetFilter() string

func (*ListRecordsRequest) GetOrderBy added in v0.2.0 

func (x *ListRecordsRequest) GetOrderBy() string

func (*ListRecordsRequest) GetPageSize 

func (x *ListRecordsRequest) GetPageSize() int32

func (*ListRecordsRequest) GetPageToken 

func (x *ListRecordsRequest) GetPageToken() string

func (*ListRecordsRequest) GetParent 

func (x *ListRecordsRequest) GetParent() string

func (*ListRecordsRequest) ProtoMessage 

func (*ListRecordsRequest) ProtoMessage()

func (*ListRecordsRequest) ProtoReflect 

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

func (*ListRecordsRequest) Reset 

func (x *ListRecordsRequest) Reset()

func (*ListRecordsRequest) String 

func (x *ListRecordsRequest) String() string

type ListRecordsResponse 

type ListRecordsResponse struct {
	Records       []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	NextPageToken string    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRecordsResponse) Descriptor deprecated 

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

Deprecated: Use ListRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListRecordsResponse) GetNextPageToken 

func (x *ListRecordsResponse) GetNextPageToken() string

func (*ListRecordsResponse) GetRecords 

func (x *ListRecordsResponse) GetRecords() []*Record

func (*ListRecordsResponse) ProtoMessage 

func (*ListRecordsResponse) ProtoMessage()

func (*ListRecordsResponse) ProtoReflect 

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

func (*ListRecordsResponse) Reset 

func (x *ListRecordsResponse) Reset()

func (*ListRecordsResponse) String 

func (x *ListRecordsResponse) String() string

type ListResultsRequest 

type ListResultsRequest struct {
	Parent    string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	Filter    string `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
	PageSize  int32  `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	OrderBy   string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResultsRequest) Descriptor deprecated 

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

Deprecated: Use ListResultsRequest.ProtoReflect.Descriptor instead.

func (*ListResultsRequest) GetFilter 

func (x *ListResultsRequest) GetFilter() string

func (*ListResultsRequest) GetOrderBy added in v0.2.0 

func (x *ListResultsRequest) GetOrderBy() string

func (*ListResultsRequest) GetPageSize 

func (x *ListResultsRequest) GetPageSize() int32

func (*ListResultsRequest) GetPageToken 

func (x *ListResultsRequest) GetPageToken() string

func (*ListResultsRequest) GetParent 

func (x *ListResultsRequest) GetParent() string

func (*ListResultsRequest) ProtoMessage 

func (*ListResultsRequest) ProtoMessage()

func (*ListResultsRequest) ProtoReflect 

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

func (*ListResultsRequest) Reset 

func (x *ListResultsRequest) Reset()

func (*ListResultsRequest) String 

func (x *ListResultsRequest) String() string

type ListResultsResponse 

type ListResultsResponse struct {
	Results       []*Result `protobuf:"bytes,1,rep,name=results,proto3" json:"results,omitempty"`
	NextPageToken string    `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResultsResponse) Descriptor deprecated 

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

Deprecated: Use ListResultsResponse.ProtoReflect.Descriptor instead.

func (*ListResultsResponse) GetNextPageToken 

func (x *ListResultsResponse) GetNextPageToken() string

func (*ListResultsResponse) GetResults 

func (x *ListResultsResponse) GetResults() []*Result

func (*ListResultsResponse) ProtoMessage 

func (*ListResultsResponse) ProtoMessage()

func (*ListResultsResponse) ProtoReflect 

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

func (*ListResultsResponse) Reset 

func (x *ListResultsResponse) Reset()

func (*ListResultsResponse) String 

func (x *ListResultsResponse) String() string

type Log added in v0.5.0 

type Log struct {

	// Resource name fo the log
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The log data
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

Log is a chunk of a log.

func (*Log) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetData added in v0.5.0 

func (x *Log) GetData() []byte

func (*Log) GetName added in v0.5.0 

func (x *Log) GetName() string

func (*Log) ProtoMessage added in v0.5.0 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect added in v0.5.0 

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

func (*Log) Reset added in v0.5.0 

func (x *Log) Reset()

func (*Log) String added in v0.5.0 

func (x *Log) String() string

type LogSummary added in v0.5.0 

type LogSummary struct {

	// The name of the Record this summary represents.
	Record string `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// Number of bytes received while streaming
	BytesReceived int64 `protobuf:"varint,2,opt,name=bytesReceived,proto3" json:"bytesReceived,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSummary) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use LogSummary.ProtoReflect.Descriptor instead.

func (*LogSummary) GetBytesReceived added in v0.5.0 

func (x *LogSummary) GetBytesReceived() int64

func (*LogSummary) GetRecord added in v0.5.0 

func (x *LogSummary) GetRecord() string

func (*LogSummary) ProtoMessage added in v0.5.0 

func (*LogSummary) ProtoMessage()

func (*LogSummary) ProtoReflect added in v0.5.0 

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

func (*LogSummary) Reset added in v0.5.0 

func (x *LogSummary) Reset()

func (*LogSummary) String added in v0.5.0 

func (x *LogSummary) String() string

type LogsClient added in v0.5.0 

type LogsClient interface {
	GetLog(ctx context.Context, in *GetLogRequest, opts ...grpc.CallOption) (Logs_GetLogClient, error)
	ListLogs(ctx context.Context, in *ListRecordsRequest, opts ...grpc.CallOption) (*ListRecordsResponse, error)
	UpdateLog(ctx context.Context, opts ...grpc.CallOption) (Logs_UpdateLogClient, error)
	DeleteLog(ctx context.Context, in *DeleteLogRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

LogsClient is the client API for Logs 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 NewLogsClient added in v0.5.0 

func NewLogsClient(cc grpc.ClientConnInterface) LogsClient

type LogsServer added in v0.5.0 

type LogsServer interface {
	GetLog(*GetLogRequest, Logs_GetLogServer) error
	ListLogs(context.Context, *ListRecordsRequest) (*ListRecordsResponse, error)
	UpdateLog(Logs_UpdateLogServer) error
	DeleteLog(context.Context, *DeleteLogRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

LogsServer is the server API for Logs service. All implementations must embed UnimplementedLogsServer for forward compatibility

type Logs_GetLogClient added in v0.5.0 

type Logs_GetLogClient interface {
	Recv() (*Log, error)
	grpc.ClientStream
}

type Logs_GetLogServer added in v0.5.0 

type Logs_GetLogServer interface {
	Send(*Log) error
	grpc.ServerStream
}

type Logs_UpdateLogClient added in v0.5.0 

type Logs_UpdateLogClient interface {
	Send(*Log) error
	CloseAndRecv() (*LogSummary, error)
	grpc.ClientStream
}

type Logs_UpdateLogServer added in v0.5.0 

type Logs_UpdateLogServer interface {
	SendAndClose(*LogSummary) error
	Recv() (*Log, error)
	grpc.ServerStream
}

type Record 

type Record struct {

	// Resource name, must be rooted in parent result.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Server assigned identifier of the Result.
	// DEPRECATED: use uid instead.
	//
	// Deprecated: Do not use.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Server assigned identifier of the Result.
	Uid  string `protobuf:"bytes,7,opt,name=uid,proto3" json:"uid,omitempty"`
	Data *Any   `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// The etag for this record.
	// If this is provided on update, it must match the server's etag.
	Etag string `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	// Server assigned timestamp for when the result was created.
	// DEPRECATED: use create_time instead.
	//
	// Deprecated: Do not use.
	CreatedTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// Server assigned timestamp for when the result was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Server assigned timestamp for when the results was updated.
	// DEPRECATED: use update_time instead.
	//
	// Deprecated: Do not use.
	UpdatedTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_time,json=updatedTime,proto3" json:"updated_time,omitempty"`
	// Server assigned timestamp for when the results was updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

Record belonging to a Result. Typically will be Tekton Task/PipelineRuns, but may also include other execution information (e.g. alternative configs, DSLs, input payloads, post-execution actions, etc.)

func (*Record) Descriptor deprecated 

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetCreateTime added in v0.3.0 

func (x *Record) GetCreateTime() *timestamppb.Timestamp

func (*Record) GetCreatedTime deprecated 

func (x *Record) GetCreatedTime() *timestamppb.Timestamp

Deprecated: Do not use.

func (*Record) GetData 

func (x *Record) GetData() *Any

func (*Record) GetEtag 

func (x *Record) GetEtag() string

func (*Record) GetId deprecated 

func (x *Record) GetId() string

Deprecated: Do not use.

func (*Record) GetName 

func (x *Record) GetName() string

func (*Record) GetUid added in v0.3.0 

func (x *Record) GetUid() string

func (*Record) GetUpdateTime added in v0.3.0 

func (x *Record) GetUpdateTime() *timestamppb.Timestamp

func (*Record) GetUpdatedTime deprecated 

func (x *Record) GetUpdatedTime() *timestamppb.Timestamp

Deprecated: Do not use.

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) ProtoReflect 

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

func (*Record) Reset 

func (x *Record) Reset()

func (*Record) String 

func (x *Record) String() string

type RecordSummary added in v0.5.0 

type RecordSummary struct {

	// The name of the Record this summary represents.
	Record string `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	// Identifier of underlying data.
	// e.g. `pipelines.tekton.dev/PipelineRun`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// Common Record agnostic fields.
	StartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Completion status of the Record.
	Status RecordSummary_Status `protobuf:"varint,5,opt,name=status,proto3,enum=tekton.results.v1alpha2.RecordSummary_Status" json:"status,omitempty"`
	// Key-value pairs representing arbitrary underlying record data that clients want to include
	// that aren't covered by the above fields.
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

RecordSummary is a high level overview of a Record, typically representing a "root" record for a result. It includes type agnostic information so that UIs and other tools do not need to be aware of underlying types.

func (*RecordSummary) Descriptor deprecated added in v0.5.0 

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

Deprecated: Use RecordSummary.ProtoReflect.Descriptor instead.

func (*RecordSummary) GetAnnotations added in v0.5.0 

func (x *RecordSummary) GetAnnotations() map[string]string

func (*RecordSummary) GetEndTime added in v0.5.0 

func (x *RecordSummary) GetEndTime() *timestamppb.Timestamp

func (*RecordSummary) GetRecord added in v0.5.0 

func (x *RecordSummary) GetRecord() string

func (*RecordSummary) GetStartTime added in v0.5.0 

func (x *RecordSummary) GetStartTime() *timestamppb.Timestamp

func (*RecordSummary) GetStatus added in v0.5.0 

func (x *RecordSummary) GetStatus() RecordSummary_Status

func (*RecordSummary) GetType added in v0.5.0 

func (x *RecordSummary) GetType() string

func (*RecordSummary) ProtoMessage added in v0.5.0 

func (*RecordSummary) ProtoMessage()

func (*RecordSummary) ProtoReflect added in v0.5.0 

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

func (*RecordSummary) Reset added in v0.5.0 

func (x *RecordSummary) Reset()

func (*RecordSummary) String added in v0.5.0 

func (x *RecordSummary) String() string

type RecordSummary_Status added in v0.5.0 

type RecordSummary_Status int32
const (
	RecordSummary_UNKNOWN   RecordSummary_Status = 0
	RecordSummary_SUCCESS   RecordSummary_Status = 1
	RecordSummary_FAILURE   RecordSummary_Status = 2
	RecordSummary_TIMEOUT   RecordSummary_Status = 3
	RecordSummary_CANCELLED RecordSummary_Status = 4
)

func (RecordSummary_Status) Descriptor added in v0.5.0 

func (RecordSummary_Status) Descriptor() protoreflect.EnumDescriptor

func (RecordSummary_Status) Enum added in v0.5.0 

func (x RecordSummary_Status) Enum() *RecordSummary_Status

func (RecordSummary_Status) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use RecordSummary_Status.Descriptor instead.

func (RecordSummary_Status) Number added in v0.5.0 

func (x RecordSummary_Status) Number() protoreflect.EnumNumber

func (RecordSummary_Status) String added in v0.5.0 

func (x RecordSummary_Status) String() string

func (RecordSummary_Status) Type added in v0.5.0 

func (RecordSummary_Status) Type() protoreflect.EnumType

type Result 

type Result struct {

	// User assigned identifier of the Result.
	// Encodes parent information.
	//
	// Examples: namespace/default/results/1234
	//           cluster/<cluster-id>/namespace/tekton/results/1234
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Server assigned identifier of the Result.
	// DEPRECATED: use uid instead.
	//
	// Deprecated: Do not use.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// Server assigned identifier of the Result.
	Uid string `protobuf:"bytes,7,opt,name=uid,proto3" json:"uid,omitempty"`
	// Server assigned timestamp for when the result was created.
	// DEPRECATED: use create_time instead.
	//
	// Deprecated: Do not use.
	CreatedTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// Server assigned timestamp for when the result was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Server assigned timestamp for when the results was updated.
	// DEPRECATED: use update_time instead.
	//
	// Deprecated: Do not use.
	UpdatedTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_time,json=updatedTime,proto3" json:"updated_time,omitempty"`
	// Server assigned timestamp for when the results was updated.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Arbitrary user provided labels for the result.
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// The etag for this result.
	// If this is provided on update, it must match the server's etag.
	Etag string `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	// High level overview of the root record for the Result. This is provided
	// as a convinence for clients to query Record state without needing to make
	// multiple calls to fetch the underlying Records.
	Summary *RecordSummary `protobuf:"bytes,10,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*Result) Descriptor deprecated 

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

Deprecated: Use Result.ProtoReflect.Descriptor instead.

func (*Result) GetAnnotations 

func (x *Result) GetAnnotations() map[string]string

func (*Result) GetCreateTime added in v0.3.0 

func (x *Result) GetCreateTime() *timestamppb.Timestamp

func (*Result) GetCreatedTime deprecated 

func (x *Result) GetCreatedTime() *timestamppb.Timestamp

Deprecated: Do not use.

func (*Result) GetEtag 

func (x *Result) GetEtag() string

func (*Result) GetId deprecated 

func (x *Result) GetId() string

Deprecated: Do not use.

func (*Result) GetName 

func (x *Result) GetName() string

func (*Result) GetSummary added in v0.5.0 

func (x *Result) GetSummary() *RecordSummary

func (*Result) GetUid added in v0.3.0 

func (x *Result) GetUid() string

func (*Result) GetUpdateTime added in v0.3.0 

func (x *Result) GetUpdateTime() *timestamppb.Timestamp

func (*Result) GetUpdatedTime deprecated 

func (x *Result) GetUpdatedTime() *timestamppb.Timestamp

Deprecated: Do not use.

func (*Result) ProtoMessage 

func (*Result) ProtoMessage()

func (*Result) ProtoReflect 

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

func (*Result) Reset 

func (x *Result) Reset()

func (*Result) String 

func (x *Result) String() string

type ResultsClient 

type ResultsClient interface {
	CreateResult(ctx context.Context, in *CreateResultRequest, opts ...grpc.CallOption) (*Result, error)
	UpdateResult(ctx context.Context, in *UpdateResultRequest, opts ...grpc.CallOption) (*Result, error)
	GetResult(ctx context.Context, in *GetResultRequest, opts ...grpc.CallOption) (*Result, error)
	DeleteResult(ctx context.Context, in *DeleteResultRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ListResults(ctx context.Context, in *ListResultsRequest, opts ...grpc.CallOption) (*ListResultsResponse, error)
	CreateRecord(ctx context.Context, in *CreateRecordRequest, opts ...grpc.CallOption) (*Record, error)
	UpdateRecord(ctx context.Context, in *UpdateRecordRequest, opts ...grpc.CallOption) (*Record, error)
	GetRecord(ctx context.Context, in *GetRecordRequest, opts ...grpc.CallOption) (*Record, error)
	ListRecords(ctx context.Context, in *ListRecordsRequest, opts ...grpc.CallOption) (*ListRecordsResponse, error)
	DeleteRecord(ctx context.Context, in *DeleteRecordRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ResultsClient is the client API for Results 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 NewResultsClient 

func NewResultsClient(cc grpc.ClientConnInterface) ResultsClient

type ResultsServer 

type ResultsServer interface {
	CreateResult(context.Context, *CreateResultRequest) (*Result, error)
	UpdateResult(context.Context, *UpdateResultRequest) (*Result, error)
	GetResult(context.Context, *GetResultRequest) (*Result, error)
	DeleteResult(context.Context, *DeleteResultRequest) (*emptypb.Empty, error)
	ListResults(context.Context, *ListResultsRequest) (*ListResultsResponse, error)
	CreateRecord(context.Context, *CreateRecordRequest) (*Record, error)
	UpdateRecord(context.Context, *UpdateRecordRequest) (*Record, error)
	GetRecord(context.Context, *GetRecordRequest) (*Record, error)
	ListRecords(context.Context, *ListRecordsRequest) (*ListRecordsResponse, error)
	DeleteRecord(context.Context, *DeleteRecordRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

ResultsServer is the server API for Results service. All implementations must embed UnimplementedResultsServer for forward compatibility

type UnimplementedLogsServer added in v0.5.0 

type UnimplementedLogsServer struct {
}

UnimplementedLogsServer must be embedded to have forward compatible implementations.

func (UnimplementedLogsServer) DeleteLog added in v0.5.0 

func (UnimplementedLogsServer) DeleteLog(context.Context, *DeleteLogRequest) (*emptypb.Empty, error)

func (UnimplementedLogsServer) GetLog added in v0.5.0 

func (UnimplementedLogsServer) GetLog(*GetLogRequest, Logs_GetLogServer) error

func (UnimplementedLogsServer) ListLogs added in v0.5.0 

func (UnimplementedLogsServer) ListLogs(context.Context, *ListRecordsRequest) (*ListRecordsResponse, error)

func (UnimplementedLogsServer) UpdateLog added in v0.5.0 

func (UnimplementedLogsServer) UpdateLog(Logs_UpdateLogServer) error

type UnimplementedResultsServer 

type UnimplementedResultsServer struct {
}

UnimplementedResultsServer must be embedded to have forward compatible implementations.

func (UnimplementedResultsServer) CreateRecord 

func (UnimplementedResultsServer) CreateRecord(context.Context, *CreateRecordRequest) (*Record, error)

func (UnimplementedResultsServer) CreateResult 

func (UnimplementedResultsServer) CreateResult(context.Context, *CreateResultRequest) (*Result, error)

func (UnimplementedResultsServer) DeleteRecord 

func (UnimplementedResultsServer) DeleteRecord(context.Context, *DeleteRecordRequest) (*emptypb.Empty, error)

func (UnimplementedResultsServer) DeleteResult 

func (UnimplementedResultsServer) DeleteResult(context.Context, *DeleteResultRequest) (*emptypb.Empty, error)

func (UnimplementedResultsServer) GetRecord 

func (UnimplementedResultsServer) GetRecord(context.Context, *GetRecordRequest) (*Record, error)

func (UnimplementedResultsServer) GetResult 

func (UnimplementedResultsServer) GetResult(context.Context, *GetResultRequest) (*Result, error)

func (UnimplementedResultsServer) ListRecords 

func (UnimplementedResultsServer) ListRecords(context.Context, *ListRecordsRequest) (*ListRecordsResponse, error)

func (UnimplementedResultsServer) ListResults 

func (UnimplementedResultsServer) ListResults(context.Context, *ListResultsRequest) (*ListResultsResponse, error)

func (UnimplementedResultsServer) UpdateRecord 

func (UnimplementedResultsServer) UpdateRecord(context.Context, *UpdateRecordRequest) (*Record, error)

func (UnimplementedResultsServer) UpdateResult 

func (UnimplementedResultsServer) UpdateResult(context.Context, *UpdateResultRequest) (*Result, error)

type UnsafeLogsServer added in v0.5.0 

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

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

type UnsafeResultsServer 

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

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

type UpdateRecordRequest 

type UpdateRecordRequest struct {
	Record     *Record                `protobuf:"bytes,1,opt,name=record,proto3" json:"record,omitempty"`
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// If set, then the request will succeed if and only if the provided etag
	// matches the server-computed value, else will fail.
	// Should be used to prevent concurrent updates from overwritting each other.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRecordRequest) Descriptor deprecated 

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

Deprecated: Use UpdateRecordRequest.ProtoReflect.Descriptor instead.

func (*UpdateRecordRequest) GetEtag 

func (x *UpdateRecordRequest) GetEtag() string

func (*UpdateRecordRequest) GetRecord 

func (x *UpdateRecordRequest) GetRecord() *Record

func (*UpdateRecordRequest) GetUpdateMask 

func (x *UpdateRecordRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateRecordRequest) ProtoMessage 

func (*UpdateRecordRequest) ProtoMessage()

func (*UpdateRecordRequest) ProtoReflect 

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

func (*UpdateRecordRequest) Reset 

func (x *UpdateRecordRequest) Reset()

func (*UpdateRecordRequest) String 

func (x *UpdateRecordRequest) String() string

type UpdateResultRequest 

type UpdateResultRequest struct {
	Name   string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Result *Result `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// If set, then the request will succeed if and only if the provided etag
	// matches the server-computed value, else will fail.
	// Should be used to prevent concurrent updates from overwritting each other.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResultRequest) Descriptor deprecated 

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

Deprecated: Use UpdateResultRequest.ProtoReflect.Descriptor instead.

func (*UpdateResultRequest) GetEtag 

func (x *UpdateResultRequest) GetEtag() string

func (*UpdateResultRequest) GetName 

func (x *UpdateResultRequest) GetName() string

func (*UpdateResultRequest) GetResult 

func (x *UpdateResultRequest) GetResult() *Result

func (*UpdateResultRequest) ProtoMessage 

func (*UpdateResultRequest) ProtoMessage()

func (*UpdateResultRequest) ProtoReflect 

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

func (*UpdateResultRequest) Reset 

func (x *UpdateResultRequest) Reset()

func (*UpdateResultRequest) String 

func (x *UpdateResultRequest) String() string

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.