logdog

package
v0.0.0-...-01cd1ea Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2024 License: Apache-2.0 Imports: 16 Imported by: 27

Documentation

Overview

Package logdog contains Version 1 of the LogDog Coordinator backend service interface.

The package name here must match the protobuf package name, as the generated files will reside in the same directory.

Index

Constants

This section is empty.

Variables

View Source 
var File_go_chromium_org_luci_logdog_api_endpoints_coordinator_services_v1_service_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_luci_logdog_api_endpoints_coordinator_services_v1_state_proto protoreflect.FileDescriptor
View Source 
var File_go_chromium_org_luci_logdog_api_endpoints_coordinator_services_v1_tasks_proto protoreflect.FileDescriptor

Functions

func FileDescriptorSet 

func FileDescriptorSet() *descriptorpb.FileDescriptorSet

FileDescriptorSet returns a descriptor set for this proto package, which includes all defined services, and all transitive dependencies.

Will not return nil.

Do NOT modify the returned descriptor.

func RegisterServicesServer 

func RegisterServicesServer(s prpc.Registrar, srv ServicesServer)

Types

type ArchiveStreamRequest 

type ArchiveStreamRequest struct {

	// The log stream's project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The Coordinator ID of the log stream that was archived.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// The number of log entries that were archived.
	LogEntryCount int64 `protobuf:"varint,3,opt,name=log_entry_count,json=logEntryCount,proto3" json:"log_entry_count,omitempty"`
	// The highest log stream index that was archived.
	TerminalIndex int64 `protobuf:"varint,4,opt,name=terminal_index,json=terminalIndex,proto3" json:"terminal_index,omitempty"`
	// If not empty, there was an archival error.
	//
	// This field serves to indicate that an error occurred (being non-empty) and
	// to supply an value that will show up in the Coordinator ArchiveStream
	// endpoint logs.
	Error string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// The archive URL of the log stream's stream data.
	StreamUrl string `protobuf:"bytes,10,opt,name=stream_url,json=streamUrl,proto3" json:"stream_url,omitempty"`
	// The size of the log stream's stream data.
	StreamSize int64 `protobuf:"varint,11,opt,name=stream_size,json=streamSize,proto3" json:"stream_size,omitempty"`
	// The archive URL of the log stream's index data.
	IndexUrl string `protobuf:"bytes,20,opt,name=index_url,json=indexUrl,proto3" json:"index_url,omitempty"`
	// The size of the log stream's index data.
	IndexSize int64 `protobuf:"varint,21,opt,name=index_size,json=indexSize,proto3" json:"index_size,omitempty"`
	// contains filtered or unexported fields
}

ArchiveStreamRequest is the set of caller-supplied data for the ArchiveStream service endpoint.

func (*ArchiveStreamRequest) Complete 

func (ar *ArchiveStreamRequest) Complete() bool

Complete returns true if the archive request expresses that the archived log stream was complete.

A log stream is complete if every entry between zero and its terminal index is included.

func (*ArchiveStreamRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveStreamRequest.ProtoReflect.Descriptor instead.

func (*ArchiveStreamRequest) GetError 

func (x *ArchiveStreamRequest) GetError() string

func (*ArchiveStreamRequest) GetId 

func (x *ArchiveStreamRequest) GetId() string

func (*ArchiveStreamRequest) GetIndexSize 

func (x *ArchiveStreamRequest) GetIndexSize() int64

func (*ArchiveStreamRequest) GetIndexUrl 

func (x *ArchiveStreamRequest) GetIndexUrl() string

func (*ArchiveStreamRequest) GetLogEntryCount 

func (x *ArchiveStreamRequest) GetLogEntryCount() int64

func (*ArchiveStreamRequest) GetMessageProject 

func (ar *ArchiveStreamRequest) GetMessageProject() string

GetMessageProject implements ProjectBoundMessage.

func (*ArchiveStreamRequest) GetProject 

func (x *ArchiveStreamRequest) GetProject() string

func (*ArchiveStreamRequest) GetStreamSize 

func (x *ArchiveStreamRequest) GetStreamSize() int64

func (*ArchiveStreamRequest) GetStreamUrl 

func (x *ArchiveStreamRequest) GetStreamUrl() string

func (*ArchiveStreamRequest) GetTerminalIndex 

func (x *ArchiveStreamRequest) GetTerminalIndex() int64

func (*ArchiveStreamRequest) ProtoMessage 

func (*ArchiveStreamRequest) ProtoMessage()

func (*ArchiveStreamRequest) ProtoReflect 

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

func (*ArchiveStreamRequest) Reset 

func (x *ArchiveStreamRequest) Reset()

func (*ArchiveStreamRequest) String 

func (x *ArchiveStreamRequest) String() string

type ArchiveTask 

type ArchiveTask struct {

	// The name of the project that this stream is bound to.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The hash ID of the log stream to archive.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// The TaskQueue Name of this task, used in the taskqueue pipeline.
	// This is required for ACKing.
	TaskName string `protobuf:"bytes,7,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	// The realm name (within the project) that the prefix of the stream is
	// associated with.
	Realm string `protobuf:"bytes,8,opt,name=realm,proto3" json:"realm,omitempty"`
	// TODO(hinoka): Remove this after crbug.com/923557
	// The archival key of the log stream. If this key doesn't match the key in
	// the log stream state, the request is superfluous and should be deleted.
	Key []byte `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

ArchiveTask is a task queue task description for the archival of a single log stream.

func (*ArchiveTask) Descriptor deprecated 

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

Deprecated: Use ArchiveTask.ProtoReflect.Descriptor instead.

func (*ArchiveTask) GetId 

func (x *ArchiveTask) GetId() string

func (*ArchiveTask) GetKey 

func (x *ArchiveTask) GetKey() []byte

func (*ArchiveTask) GetProject 

func (x *ArchiveTask) GetProject() string

func (*ArchiveTask) GetRealm 

func (x *ArchiveTask) GetRealm() string

func (*ArchiveTask) GetTaskName 

func (x *ArchiveTask) GetTaskName() string

func (*ArchiveTask) ProtoMessage 

func (*ArchiveTask) ProtoMessage()

func (*ArchiveTask) ProtoReflect 

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

func (*ArchiveTask) Reset 

func (x *ArchiveTask) Reset()

func (*ArchiveTask) String 

func (x *ArchiveTask) String() string

type BatchRequest 

type BatchRequest struct {
	Req []*BatchRequest_Entry `protobuf:"bytes,1,rep,name=req,proto3" json:"req,omitempty"`
	// contains filtered or unexported fields
}

BatchRequest is a batch of individual requests to make to the Coordinator.

func (*BatchRequest) Descriptor deprecated 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetReq 

func (x *BatchRequest) GetReq() []*BatchRequest_Entry

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect 

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

func (*BatchRequest) Reset 

func (x *BatchRequest) Reset()

func (*BatchRequest) String 

func (x *BatchRequest) String() string

type BatchRequest_Entry 

type BatchRequest_Entry struct {

	// Types that are assignable to Value:
	//
	//	*BatchRequest_Entry_RegisterStream
	//	*BatchRequest_Entry_LoadStream
	//	*BatchRequest_Entry_TerminateStream
	//	*BatchRequest_Entry_ArchiveStream
	Value isBatchRequest_Entry_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

The collection of batched requests.

func (*BatchRequest_Entry) Descriptor deprecated 

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

Deprecated: Use BatchRequest_Entry.ProtoReflect.Descriptor instead.

func (*BatchRequest_Entry) GetArchiveStream 

func (x *BatchRequest_Entry) GetArchiveStream() *ArchiveStreamRequest

func (*BatchRequest_Entry) GetLoadStream 

func (x *BatchRequest_Entry) GetLoadStream() *LoadStreamRequest

func (*BatchRequest_Entry) GetRegisterStream 

func (x *BatchRequest_Entry) GetRegisterStream() *RegisterStreamRequest

func (*BatchRequest_Entry) GetTerminateStream 

func (x *BatchRequest_Entry) GetTerminateStream() *TerminateStreamRequest

func (*BatchRequest_Entry) GetValue 

func (m *BatchRequest_Entry) GetValue() isBatchRequest_Entry_Value

func (*BatchRequest_Entry) ProtoMessage 

func (*BatchRequest_Entry) ProtoMessage()

func (*BatchRequest_Entry) ProtoReflect 

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

func (*BatchRequest_Entry) Reset 

func (x *BatchRequest_Entry) Reset()

func (*BatchRequest_Entry) String 

func (x *BatchRequest_Entry) String() string

type BatchRequest_Entry_ArchiveStream 

type BatchRequest_Entry_ArchiveStream struct {
	ArchiveStream *ArchiveStreamRequest `protobuf:"bytes,4,opt,name=archive_stream,json=archiveStream,proto3,oneof"`
}

type BatchRequest_Entry_LoadStream 

type BatchRequest_Entry_LoadStream struct {
	LoadStream *LoadStreamRequest `protobuf:"bytes,2,opt,name=load_stream,json=loadStream,proto3,oneof"`
}

type BatchRequest_Entry_RegisterStream 

type BatchRequest_Entry_RegisterStream struct {
	RegisterStream *RegisterStreamRequest `protobuf:"bytes,1,opt,name=register_stream,json=registerStream,proto3,oneof"`
}

type BatchRequest_Entry_TerminateStream 

type BatchRequest_Entry_TerminateStream struct {
	TerminateStream *TerminateStreamRequest `protobuf:"bytes,3,opt,name=terminate_stream,json=terminateStream,proto3,oneof"`
}

type BatchResponse 

type BatchResponse struct {
	Resp []*BatchResponse_Entry `protobuf:"bytes,1,rep,name=resp,proto3" json:"resp,omitempty"`
	// contains filtered or unexported fields
}

BatchResponse is a response to a BatchRequest.

func (*BatchResponse) Descriptor deprecated 

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

Deprecated: Use BatchResponse.ProtoReflect.Descriptor instead.

func (*BatchResponse) GetResp 

func (x *BatchResponse) GetResp() []*BatchResponse_Entry

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) ProtoReflect 

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

func (*BatchResponse) Reset 

func (x *BatchResponse) Reset()

func (*BatchResponse) String 

func (x *BatchResponse) String() string

type BatchResponse_Entry 

type BatchResponse_Entry struct {

	// The index in the BatchRequest for this entry.
	Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	// Types that are assignable to Value:
	//
	//	*BatchResponse_Entry_Err
	//	*BatchResponse_Entry_RegisterStream
	//	*BatchResponse_Entry_LoadStream
	Value isBatchResponse_Entry_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

The collection of batched requests.

Each entry corresponds to the BatchRequest entry with the specified index.

Entry objects may appear out of order with their request indexes. Some responses may also be missing, if the remote end could not provide them due to constraints (e.g., size, time).

func (*BatchResponse_Entry) Descriptor deprecated 

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

Deprecated: Use BatchResponse_Entry.ProtoReflect.Descriptor instead.

func (*BatchResponse_Entry) GetErr 

func (x *BatchResponse_Entry) GetErr() *Error

func (*BatchResponse_Entry) GetIndex 

func (x *BatchResponse_Entry) GetIndex() int32

func (*BatchResponse_Entry) GetLoadStream 

func (x *BatchResponse_Entry) GetLoadStream() *LoadStreamResponse

func (*BatchResponse_Entry) GetRegisterStream 

func (x *BatchResponse_Entry) GetRegisterStream() *RegisterStreamResponse

func (*BatchResponse_Entry) GetValue 

func (m *BatchResponse_Entry) GetValue() isBatchResponse_Entry_Value

func (*BatchResponse_Entry) ProtoMessage 

func (*BatchResponse_Entry) ProtoMessage()

func (*BatchResponse_Entry) ProtoReflect 

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

func (*BatchResponse_Entry) Reset 

func (x *BatchResponse_Entry) Reset()

func (*BatchResponse_Entry) String 

func (x *BatchResponse_Entry) String() string

type BatchResponse_Entry_Err 

type BatchResponse_Entry_Err struct {
	Err *Error `protobuf:"bytes,2,opt,name=err,proto3,oneof"`
}

type BatchResponse_Entry_LoadStream 

type BatchResponse_Entry_LoadStream struct {
	LoadStream *LoadStreamResponse `protobuf:"bytes,4,opt,name=load_stream,json=loadStream,proto3,oneof"`
}

type BatchResponse_Entry_RegisterStream 

type BatchResponse_Entry_RegisterStream struct {
	RegisterStream *RegisterStreamResponse `protobuf:"bytes,3,opt,name=register_stream,json=registerStream,proto3,oneof"`
}

type DecoratedServices 

type DecoratedServices struct {
	// Service is the service to decorate.
	Service ServicesServer
	// Prelude is called for each method before forwarding the call to Service.
	// If Prelude returns an error, then the call is skipped and the error is
	// processed via the Postlude (if one is defined), or it is returned directly.
	Prelude func(ctx context.Context, methodName string, req proto.Message) (context.Context, error)
	// Postlude is called for each method after Service has processed the call, or
	// after the Prelude has returned an error. This takes the Service's
	// response proto (which may be nil) and/or any error. The decorated
	// service will return the response (possibly mutated) and error that Postlude
	// returns.
	Postlude func(ctx context.Context, methodName string, rsp proto.Message, err error) error
}

func (*DecoratedServices) ArchiveStream 

func (s *DecoratedServices) ArchiveStream(ctx context.Context, req *ArchiveStreamRequest) (rsp *emptypb.Empty, err error)

func (*DecoratedServices) Batch 

func (s *DecoratedServices) Batch(ctx context.Context, req *BatchRequest) (rsp *BatchResponse, err error)

func (*DecoratedServices) DeleteArchiveTasks 

func (s *DecoratedServices) DeleteArchiveTasks(ctx context.Context, req *DeleteRequest) (rsp *emptypb.Empty, err error)

func (*DecoratedServices) LeaseArchiveTasks 

func (s *DecoratedServices) LeaseArchiveTasks(ctx context.Context, req *LeaseRequest) (rsp *LeaseResponse, err error)

func (*DecoratedServices) LoadStream 

func (s *DecoratedServices) LoadStream(ctx context.Context, req *LoadStreamRequest) (rsp *LoadStreamResponse, err error)

func (*DecoratedServices) RegisterStream 

func (s *DecoratedServices) RegisterStream(ctx context.Context, req *RegisterStreamRequest) (rsp *RegisterStreamResponse, err error)

func (*DecoratedServices) TerminateStream 

func (s *DecoratedServices) TerminateStream(ctx context.Context, req *TerminateStreamRequest) (rsp *emptypb.Empty, err error)

type DeleteRequest 

type DeleteRequest struct {

	// Tasks are tasks the caller wants to delete.  Only Project and Id are required.
	Tasks []*ArchiveTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteRequest) Descriptor deprecated 

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

Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.

func (*DeleteRequest) GetTasks 

func (x *DeleteRequest) GetTasks() []*ArchiveTask

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) ProtoReflect 

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

func (*DeleteRequest) Reset 

func (x *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (x *DeleteRequest) String() string

type Error 

type Error struct {

	// The gRPC code for this error.
	GrpcCode int32 `protobuf:"varint,1,opt,name=grpc_code,json=grpcCode,proto3" json:"grpc_code,omitempty"`
	// Transient is true if this is a transient error.
	Transient bool `protobuf:"varint,2,opt,name=transient,proto3" json:"transient,omitempty"`
	// An optional associated message.
	Msg string `protobuf:"bytes,3,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

Error is a projection of a gRPC error.

NOTE: This and its helper functions may be useful more generally. Maybe transplant this to a more general place such as "//grpc" if it ends up being useful.

func MakeError 

func MakeError(err error) *Error

MakeError returns an Error object for err to return as part of RPC response.

If err is a wrapped gRPC error, its code will be extracted and embedded in the returned Error.

Following codes are considered transient: codes.Internal, codes.Unknown, codes.Unavailable, codes.DeadlineExceeded. Additionally any error tagged with transient.Tag is also considered transient.

The Msg field will not be populated.

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetGrpcCode 

func (x *Error) GetGrpcCode() int32

func (*Error) GetMsg 

func (x *Error) GetMsg() string

func (*Error) GetTransient 

func (x *Error) GetTransient() bool

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

func (*Error) ToError 

func (e *Error) ToError() error

ToError converts an Error into a gRPC error. If e is nil, a nil error will be returned.

type InternalLogStreamState 

type InternalLogStreamState struct {

	// ProtoVersion is the protobuf version for this stream.
	ProtoVersion string `protobuf:"bytes,1,opt,name=proto_version,json=protoVersion,proto3" json:"proto_version,omitempty"`
	// The log stream's secret.
	//
	// Note that the secret is returned! This is okay, since this endpoint is only
	// accessible to trusted services. The secret can be cached by services to
	// validate stream information without needing to ping the Coordinator in
	// between each update.
	Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// The stream index of the log stream's terminal message. If the value is -1,
	// the log is still streaming.
	TerminalIndex int64 `protobuf:"varint,3,opt,name=terminal_index,json=terminalIndex,proto3" json:"terminal_index,omitempty"`
	// If the log stream has been archived.
	Archived bool `protobuf:"varint,4,opt,name=archived,proto3" json:"archived,omitempty"`
	// If the log stream has been purged.
	Purged bool `protobuf:"varint,5,opt,name=purged,proto3" json:"purged,omitempty"`
	// contains filtered or unexported fields
}

InternalLogStreamState is the log stream state value communicated to services.

func (*InternalLogStreamState) Descriptor deprecated 

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

Deprecated: Use InternalLogStreamState.ProtoReflect.Descriptor instead.

func (*InternalLogStreamState) GetArchived 

func (x *InternalLogStreamState) GetArchived() bool

func (*InternalLogStreamState) GetProtoVersion 

func (x *InternalLogStreamState) GetProtoVersion() string

func (*InternalLogStreamState) GetPurged 

func (x *InternalLogStreamState) GetPurged() bool

func (*InternalLogStreamState) GetSecret 

func (x *InternalLogStreamState) GetSecret() []byte

func (*InternalLogStreamState) GetTerminalIndex 

func (x *InternalLogStreamState) GetTerminalIndex() int64

func (*InternalLogStreamState) ProtoMessage 

func (*InternalLogStreamState) ProtoMessage()

func (*InternalLogStreamState) ProtoReflect 

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

func (*InternalLogStreamState) Reset 

func (x *InternalLogStreamState) Reset()

func (*InternalLogStreamState) String 

func (x *InternalLogStreamState) String() string

type LeaseRequest 

type LeaseRequest struct {
	MaxTasks  int64                `protobuf:"varint,1,opt,name=max_tasks,json=maxTasks,proto3" json:"max_tasks,omitempty"`
	LeaseTime *durationpb.Duration `protobuf:"bytes,2,opt,name=lease_time,json=leaseTime,proto3" json:"lease_time,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseRequest) Descriptor deprecated 

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

Deprecated: Use LeaseRequest.ProtoReflect.Descriptor instead.

func (*LeaseRequest) GetLeaseTime 

func (x *LeaseRequest) GetLeaseTime() *durationpb.Duration

func (*LeaseRequest) GetMaxTasks 

func (x *LeaseRequest) GetMaxTasks() int64

func (*LeaseRequest) ProtoMessage 

func (*LeaseRequest) ProtoMessage()

func (*LeaseRequest) ProtoReflect 

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

func (*LeaseRequest) Reset 

func (x *LeaseRequest) Reset()

func (*LeaseRequest) String 

func (x *LeaseRequest) String() string

type LeaseResponse 

type LeaseResponse struct {

	// Tasks are tasks leased to the caller.  Only Project and Id are filled.
	Tasks []*ArchiveTask `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*LeaseResponse) Descriptor deprecated 

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

Deprecated: Use LeaseResponse.ProtoReflect.Descriptor instead.

func (*LeaseResponse) GetTasks 

func (x *LeaseResponse) GetTasks() []*ArchiveTask

func (*LeaseResponse) ProtoMessage 

func (*LeaseResponse) ProtoMessage()

func (*LeaseResponse) ProtoReflect 

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

func (*LeaseResponse) Reset 

func (x *LeaseResponse) Reset()

func (*LeaseResponse) String 

func (x *LeaseResponse) String() string

type LoadStreamRequest 

type LoadStreamRequest struct {

	// The log stream's project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The log stream's path Coordinator ID.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// If true, include the log stream descriptor.
	Desc bool `protobuf:"varint,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// contains filtered or unexported fields
}

LoadStreamRequest loads the current state of a log stream.

func (*LoadStreamRequest) Descriptor deprecated 

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

Deprecated: Use LoadStreamRequest.ProtoReflect.Descriptor instead.

func (*LoadStreamRequest) GetDesc 

func (x *LoadStreamRequest) GetDesc() bool

func (*LoadStreamRequest) GetId 

func (x *LoadStreamRequest) GetId() string

func (*LoadStreamRequest) GetMessageProject 

func (ar *LoadStreamRequest) GetMessageProject() string

GetMessageProject implements ProjectBoundMessage.

func (*LoadStreamRequest) GetProject 

func (x *LoadStreamRequest) GetProject() string

func (*LoadStreamRequest) ProtoMessage 

func (*LoadStreamRequest) ProtoMessage()

func (*LoadStreamRequest) ProtoReflect 

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

func (*LoadStreamRequest) Reset 

func (x *LoadStreamRequest) Reset()

func (*LoadStreamRequest) String 

func (x *LoadStreamRequest) String() string

type LoadStreamResponse 

type LoadStreamResponse struct {

	// The state of the requested log stream.
	State *InternalLogStreamState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// If requested, the serialized log stream descriptor. The protobuf version
	// of this descriptor will match the "proto_version" field in "state".
	Desc []byte `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// The age of the log stream.
	Age *durationpb.Duration `protobuf:"bytes,3,opt,name=age,proto3" json:"age,omitempty"`
	// The archival key of the log stream. If this key doesn't match the key in
	// the archival request, the request is superfluous and should be deleted.
	ArchivalKey []byte `protobuf:"bytes,4,opt,name=archival_key,json=archivalKey,proto3" json:"archival_key,omitempty"`
	// contains filtered or unexported fields
}

The response message for the LoadStream RPC.

func (*LoadStreamResponse) Descriptor deprecated 

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

Deprecated: Use LoadStreamResponse.ProtoReflect.Descriptor instead.

func (*LoadStreamResponse) GetAge 

func (x *LoadStreamResponse) GetAge() *durationpb.Duration

func (*LoadStreamResponse) GetArchivalKey 

func (x *LoadStreamResponse) GetArchivalKey() []byte

func (*LoadStreamResponse) GetDesc 

func (x *LoadStreamResponse) GetDesc() []byte

func (*LoadStreamResponse) GetState 

func (x *LoadStreamResponse) GetState() *InternalLogStreamState

func (*LoadStreamResponse) ProtoMessage 

func (*LoadStreamResponse) ProtoMessage()

func (*LoadStreamResponse) ProtoReflect 

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

func (*LoadStreamResponse) Reset 

func (x *LoadStreamResponse) Reset()

func (*LoadStreamResponse) String 

func (x *LoadStreamResponse) String() string

type RegisterStreamRequest 

type RegisterStreamRequest struct {

	// The log stream's project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The log stream's secret.
	Secret []byte `protobuf:"bytes,2,opt,name=secret,proto3" json:"secret,omitempty"`
	// The protobuf version string for this stream.
	ProtoVersion string `protobuf:"bytes,3,opt,name=proto_version,json=protoVersion,proto3" json:"proto_version,omitempty"`
	// The serialized LogStreamDescriptor protobuf for this stream.
	Desc []byte `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	// The stream's terminal index. If >= 0, the terminal index will be set
	// in the registration request, avoiding the need for an additional
	// termination RPC.
	TerminalIndex int64 `protobuf:"varint,5,opt,name=terminal_index,json=terminalIndex,proto3" json:"terminal_index,omitempty"`
	// contains filtered or unexported fields
}

RegisterStreamRequest is the set of caller-supplied data for the RegisterStream Coordinator service endpoint.

func (*RegisterStreamRequest) Descriptor deprecated 

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

Deprecated: Use RegisterStreamRequest.ProtoReflect.Descriptor instead.

func (*RegisterStreamRequest) GetDesc 

func (x *RegisterStreamRequest) GetDesc() []byte

func (*RegisterStreamRequest) GetMessageProject 

func (ar *RegisterStreamRequest) GetMessageProject() string

GetMessageProject implements ProjectBoundMessage.

func (*RegisterStreamRequest) GetProject 

func (x *RegisterStreamRequest) GetProject() string

func (*RegisterStreamRequest) GetProtoVersion 

func (x *RegisterStreamRequest) GetProtoVersion() string

func (*RegisterStreamRequest) GetSecret 

func (x *RegisterStreamRequest) GetSecret() []byte

func (*RegisterStreamRequest) GetTerminalIndex 

func (x *RegisterStreamRequest) GetTerminalIndex() int64

func (*RegisterStreamRequest) ProtoMessage 

func (*RegisterStreamRequest) ProtoMessage()

func (*RegisterStreamRequest) ProtoReflect 

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

func (*RegisterStreamRequest) Reset 

func (x *RegisterStreamRequest) Reset()

func (*RegisterStreamRequest) String 

func (x *RegisterStreamRequest) String() string

type RegisterStreamResponse 

type RegisterStreamResponse struct {

	// The Coordinator ID of the log stream.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The state of the requested log stream.
	State *InternalLogStreamState `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	// Error is the error response.
	Error *Error `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

The response message for the RegisterStream RPC.

func (*RegisterStreamResponse) Descriptor deprecated 

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

Deprecated: Use RegisterStreamResponse.ProtoReflect.Descriptor instead.

func (*RegisterStreamResponse) GetError 

func (x *RegisterStreamResponse) GetError() *Error

func (*RegisterStreamResponse) GetId 

func (x *RegisterStreamResponse) GetId() string

func (*RegisterStreamResponse) GetState 

func (x *RegisterStreamResponse) GetState() *InternalLogStreamState

func (*RegisterStreamResponse) ProtoMessage 

func (*RegisterStreamResponse) ProtoMessage()

func (*RegisterStreamResponse) ProtoReflect 

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

func (*RegisterStreamResponse) Reset 

func (x *RegisterStreamResponse) Reset()

func (*RegisterStreamResponse) String 

func (x *RegisterStreamResponse) String() string

type ServicesClient 

type ServicesClient interface {
	// RegisterStream is an idempotent stream state register operation.
	RegisterStream(ctx context.Context, in *RegisterStreamRequest, opts ...grpc.CallOption) (*RegisterStreamResponse, error)
	// LoadStream loads the current state of a log stream.
	LoadStream(ctx context.Context, in *LoadStreamRequest, opts ...grpc.CallOption) (*LoadStreamResponse, error)
	// TerminateStream is an idempotent operation to update the stream's terminal
	// index.
	TerminateStream(ctx context.Context, in *TerminateStreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// ArchiveStream is an idempotent operation to record a log stream's archival
	// parameters. It is used by the Archivist service upon successful stream
	// archival.
	ArchiveStream(ctx context.Context, in *ArchiveStreamRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Batch is a series of requests submitted in batch. It returns a
	// BatchResponse containing the same number of entries, with each entry index
	// corresponding to its request index.
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	// TaskQueueLease is a passthrough to appengine's taskqueue.Lease.
	// TODO(hinoka): Remove this when https://cloud.google.com/tasks/ is out of Beta.
	LeaseArchiveTasks(ctx context.Context, in *LeaseRequest, opts ...grpc.CallOption) (*LeaseResponse, error)
	// TaskQueueDeleteMulti is a passthrough to appengine's taskqueue.DeleteMulti
	// TODO(hinoka): Remove this when https://cloud.google.com/tasks/ is out of Beta.
	DeleteArchiveTasks(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

ServicesClient is the client API for Services service.

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

func NewServicesClient 

func NewServicesClient(cc grpc.ClientConnInterface) ServicesClient

func NewServicesPRPCClient 

func NewServicesPRPCClient(client *prpc.Client) ServicesClient

type ServicesServer 

type ServicesServer interface {
	// RegisterStream is an idempotent stream state register operation.
	RegisterStream(context.Context, *RegisterStreamRequest) (*RegisterStreamResponse, error)
	// LoadStream loads the current state of a log stream.
	LoadStream(context.Context, *LoadStreamRequest) (*LoadStreamResponse, error)
	// TerminateStream is an idempotent operation to update the stream's terminal
	// index.
	TerminateStream(context.Context, *TerminateStreamRequest) (*emptypb.Empty, error)
	// ArchiveStream is an idempotent operation to record a log stream's archival
	// parameters. It is used by the Archivist service upon successful stream
	// archival.
	ArchiveStream(context.Context, *ArchiveStreamRequest) (*emptypb.Empty, error)
	// Batch is a series of requests submitted in batch. It returns a
	// BatchResponse containing the same number of entries, with each entry index
	// corresponding to its request index.
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
	// TaskQueueLease is a passthrough to appengine's taskqueue.Lease.
	// TODO(hinoka): Remove this when https://cloud.google.com/tasks/ is out of Beta.
	LeaseArchiveTasks(context.Context, *LeaseRequest) (*LeaseResponse, error)
	// TaskQueueDeleteMulti is a passthrough to appengine's taskqueue.DeleteMulti
	// TODO(hinoka): Remove this when https://cloud.google.com/tasks/ is out of Beta.
	DeleteArchiveTasks(context.Context, *DeleteRequest) (*emptypb.Empty, error)
}

ServicesServer is the server API for Services service.

type TerminateStreamRequest 

type TerminateStreamRequest struct {

	// The log stream's project.
	Project string `protobuf:"bytes,1,opt,name=project,proto3" json:"project,omitempty"`
	// The log stream's path Coordinator ID.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// The log stream's secret.
	Secret []byte `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
	// The terminal index of the stream.
	TerminalIndex int64 `protobuf:"varint,4,opt,name=terminal_index,json=terminalIndex,proto3" json:"terminal_index,omitempty"`
	// contains filtered or unexported fields
}

TerminateStreamRequest is the set of caller-supplied data for the TerminateStream service endpoint.

func (*TerminateStreamRequest) Descriptor deprecated 

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

Deprecated: Use TerminateStreamRequest.ProtoReflect.Descriptor instead.

func (*TerminateStreamRequest) GetId 

func (x *TerminateStreamRequest) GetId() string

func (*TerminateStreamRequest) GetMessageProject 

func (ar *TerminateStreamRequest) GetMessageProject() string

GetMessageProject implements ProjectBoundMessage.

func (*TerminateStreamRequest) GetProject 

func (x *TerminateStreamRequest) GetProject() string

func (*TerminateStreamRequest) GetSecret 

func (x *TerminateStreamRequest) GetSecret() []byte

func (*TerminateStreamRequest) GetTerminalIndex 

func (x *TerminateStreamRequest) GetTerminalIndex() int64

func (*TerminateStreamRequest) ProtoMessage 

func (*TerminateStreamRequest) ProtoMessage()

func (*TerminateStreamRequest) ProtoReflect 

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

func (*TerminateStreamRequest) Reset 

func (x *TerminateStreamRequest) Reset()

func (*TerminateStreamRequest) String 

func (x *TerminateStreamRequest) String() string

type UnimplementedServicesServer 

type UnimplementedServicesServer struct {
}

UnimplementedServicesServer can be embedded to have forward compatible implementations.

func (*UnimplementedServicesServer) ArchiveStream 

func (*UnimplementedServicesServer) ArchiveStream(context.Context, *ArchiveStreamRequest) (*emptypb.Empty, error)

func (*UnimplementedServicesServer) Batch 

func (*UnimplementedServicesServer) Batch(context.Context, *BatchRequest) (*BatchResponse, error)

func (*UnimplementedServicesServer) DeleteArchiveTasks 

func (*UnimplementedServicesServer) DeleteArchiveTasks(context.Context, *DeleteRequest) (*emptypb.Empty, error)

func (*UnimplementedServicesServer) LeaseArchiveTasks 

func (*UnimplementedServicesServer) LeaseArchiveTasks(context.Context, *LeaseRequest) (*LeaseResponse, error)

func (*UnimplementedServicesServer) LoadStream 

func (*UnimplementedServicesServer) LoadStream(context.Context, *LoadStreamRequest) (*LoadStreamResponse, error)

func (*UnimplementedServicesServer) RegisterStream 

func (*UnimplementedServicesServer) RegisterStream(context.Context, *RegisterStreamRequest) (*RegisterStreamResponse, error)

func (*UnimplementedServicesServer) TerminateStream 

func (*UnimplementedServicesServer) TerminateStream(context.Context, *TerminateStreamRequest) (*emptypb.Empty, 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.