plspb

package
v0.0.0-...-084323b Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2022 License: Apache-2.0 Imports: 9 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Credential_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plspb.Credential",
	HandlerType: (*CredentialServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Issue",
			Handler:    _Credential_Issue_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _Credential_Refresh_Handler,
		},
		{
			MethodName: "Revoke",
			Handler:    _Credential_Revoke_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pls.proto",
}

Credential_ServiceDesc is the grpc.ServiceDesc for Credential 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 File_pls_proto protoreflect.FileDescriptor
View Source 
var Log_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plspb.Log",
	HandlerType: (*LogServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Log_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Log_Delete_Handler,
		},
		{
			MethodName: "MessageAppend",
			Handler:    _Log_MessageAppend_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "List",
			Handler:       _Log_List_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "MessageList",
			Handler:       _Log_MessageList_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "pls.proto",
}

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

Functions

func RegisterCredentialServer 

func RegisterCredentialServer(s grpc.ServiceRegistrar, srv CredentialServer)

func RegisterLogServer 

func RegisterLogServer(s grpc.ServiceRegistrar, srv LogServer)

Types

type CredentialClient 

type CredentialClient interface {
	// Issue creates a new token.
	//
	// If this request is authorized, a child token is created. The child token's
	// expiration may not exceed the expiration of the parent, and the child
	// token's contexts must be a subset of the parent's. When the parent token
	// is deleted, so are any children.
	Issue(ctx context.Context, in *CredentialIssueRequest, opts ...grpc.CallOption) (*CredentialIssueResponse, error)
	// Refresh reissues a token with a new expiration. The returned credential
	// may or may not reuse the same identifier as the request.
	Refresh(ctx context.Context, in *CredentialRefreshRequest, opts ...grpc.CallOption) (*CredentialRefreshResponse, error)
	// Revoke deletes a token and prevents it from being used again. Any children
	// of the token are also revoked.
	Revoke(ctx context.Context, in *CredentialRevokeRequest, opts ...grpc.CallOption) (*CredentialRevokeResponse, error)
}

CredentialClient is the client API for Credential 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 NewCredentialClient 

func NewCredentialClient(cc grpc.ClientConnInterface) CredentialClient

type CredentialIssueRequest 

type CredentialIssueRequest struct {

	// contexts is the list of allowed log storage contexts for this credential.
	Contexts []string `protobuf:"bytes,1,rep,name=contexts,proto3" json:"contexts,omitempty"`
	// expires_at indicates when this credential should expire.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialIssueRequest) Descriptor deprecated 

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

Deprecated: Use CredentialIssueRequest.ProtoReflect.Descriptor instead.

func (*CredentialIssueRequest) GetContexts 

func (x *CredentialIssueRequest) GetContexts() []string

func (*CredentialIssueRequest) GetExpiresAt 

func (x *CredentialIssueRequest) GetExpiresAt() *timestamppb.Timestamp

func (*CredentialIssueRequest) ProtoMessage 

func (*CredentialIssueRequest) ProtoMessage()

func (*CredentialIssueRequest) ProtoReflect 

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

func (*CredentialIssueRequest) Reset 

func (x *CredentialIssueRequest) Reset()

func (*CredentialIssueRequest) String 

func (x *CredentialIssueRequest) String() string

type CredentialIssueResponse 

type CredentialIssueResponse struct {

	// credential_id is the unique public identifier for this credential.
	CredentialId string `protobuf:"bytes,1,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	// contexts is the list of contexts actually granted to this token. It will
	// be a subset of the requested contexts.
	Contexts []string `protobuf:"bytes,2,rep,name=contexts,proto3" json:"contexts,omitempty"`
	// expires_at indicates when this credential actually expires. It will be on
	// or before the requested expiration.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// token is the opaque authentication token for this credential to be passed
	// to other RPC calls.
	Token string `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialIssueResponse) Descriptor deprecated 

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

Deprecated: Use CredentialIssueResponse.ProtoReflect.Descriptor instead.

func (*CredentialIssueResponse) GetContexts 

func (x *CredentialIssueResponse) GetContexts() []string

func (*CredentialIssueResponse) GetCredentialId 

func (x *CredentialIssueResponse) GetCredentialId() string

func (*CredentialIssueResponse) GetExpiresAt 

func (x *CredentialIssueResponse) GetExpiresAt() *timestamppb.Timestamp

func (*CredentialIssueResponse) GetToken 

func (x *CredentialIssueResponse) GetToken() string

func (*CredentialIssueResponse) ProtoMessage 

func (*CredentialIssueResponse) ProtoMessage()

func (*CredentialIssueResponse) ProtoReflect 

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

func (*CredentialIssueResponse) Reset 

func (x *CredentialIssueResponse) Reset()

func (*CredentialIssueResponse) String 

func (x *CredentialIssueResponse) String() string

type CredentialRefreshRequest 

type CredentialRefreshRequest struct {

	// credential_id is the public identifier for the credential to refresh. If
	// not provided, the credential authenticating this request will be refreshed.
	// The credential must be that of the authenticated token or one of its
	// children.
	CredentialId string `protobuf:"bytes,1,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	// expires_at is the desired new expiration for the given credential.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialRefreshRequest) Descriptor deprecated 

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

Deprecated: Use CredentialRefreshRequest.ProtoReflect.Descriptor instead.

func (*CredentialRefreshRequest) GetCredentialId 

func (x *CredentialRefreshRequest) GetCredentialId() string

func (*CredentialRefreshRequest) GetExpiresAt 

func (x *CredentialRefreshRequest) GetExpiresAt() *timestamppb.Timestamp

func (*CredentialRefreshRequest) ProtoMessage 

func (*CredentialRefreshRequest) ProtoMessage()

func (*CredentialRefreshRequest) ProtoReflect 

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

func (*CredentialRefreshRequest) Reset 

func (x *CredentialRefreshRequest) Reset()

func (*CredentialRefreshRequest) String 

func (x *CredentialRefreshRequest) String() string

type CredentialRefreshResponse 

type CredentialRefreshResponse struct {

	// credential_id is the unique public identifier for the refreshed credential.
	CredentialId string `protobuf:"bytes,1,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	// expires_at is the new expiry for the credential. It will be on or before
	// the requested expiration.
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// token is the new opaque authentication token for this credential. Any
	// previously issued token for this credential are invalidated.
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialRefreshResponse) Descriptor deprecated 

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

Deprecated: Use CredentialRefreshResponse.ProtoReflect.Descriptor instead.

func (*CredentialRefreshResponse) GetCredentialId 

func (x *CredentialRefreshResponse) GetCredentialId() string

func (*CredentialRefreshResponse) GetExpiresAt 

func (x *CredentialRefreshResponse) GetExpiresAt() *timestamppb.Timestamp

func (*CredentialRefreshResponse) GetToken 

func (x *CredentialRefreshResponse) GetToken() string

func (*CredentialRefreshResponse) ProtoMessage 

func (*CredentialRefreshResponse) ProtoMessage()

func (*CredentialRefreshResponse) ProtoReflect 

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

func (*CredentialRefreshResponse) Reset 

func (x *CredentialRefreshResponse) Reset()

func (*CredentialRefreshResponse) String 

func (x *CredentialRefreshResponse) String() string

type CredentialRevokeRequest 

type CredentialRevokeRequest struct {

	// credential_id is the public identifier for the credential to revoke. If
	// not provided, the credential authenticating this request will be revoked.
	// The credential must be that of the authenticated token or one of its
	// children.
	CredentialId string `protobuf:"bytes,1,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialRevokeRequest) Descriptor deprecated 

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

Deprecated: Use CredentialRevokeRequest.ProtoReflect.Descriptor instead.

func (*CredentialRevokeRequest) GetCredentialId 

func (x *CredentialRevokeRequest) GetCredentialId() string

func (*CredentialRevokeRequest) ProtoMessage 

func (*CredentialRevokeRequest) ProtoMessage()

func (*CredentialRevokeRequest) ProtoReflect 

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

func (*CredentialRevokeRequest) Reset 

func (x *CredentialRevokeRequest) Reset()

func (*CredentialRevokeRequest) String 

func (x *CredentialRevokeRequest) String() string

type CredentialRevokeResponse 

type CredentialRevokeResponse struct {

	// credential_id is the unique public identifier of the revoked credential.
	CredentialId string `protobuf:"bytes,1,opt,name=credential_id,json=credentialId,proto3" json:"credential_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CredentialRevokeResponse) Descriptor deprecated 

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

Deprecated: Use CredentialRevokeResponse.ProtoReflect.Descriptor instead.

func (*CredentialRevokeResponse) GetCredentialId 

func (x *CredentialRevokeResponse) GetCredentialId() string

func (*CredentialRevokeResponse) ProtoMessage 

func (*CredentialRevokeResponse) ProtoMessage()

func (*CredentialRevokeResponse) ProtoReflect 

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

func (*CredentialRevokeResponse) Reset 

func (x *CredentialRevokeResponse) Reset()

func (*CredentialRevokeResponse) String 

func (x *CredentialRevokeResponse) String() string

type CredentialServer 

type CredentialServer interface {
	// Issue creates a new token.
	//
	// If this request is authorized, a child token is created. The child token's
	// expiration may not exceed the expiration of the parent, and the child
	// token's contexts must be a subset of the parent's. When the parent token
	// is deleted, so are any children.
	Issue(context.Context, *CredentialIssueRequest) (*CredentialIssueResponse, error)
	// Refresh reissues a token with a new expiration. The returned credential
	// may or may not reuse the same identifier as the request.
	Refresh(context.Context, *CredentialRefreshRequest) (*CredentialRefreshResponse, error)
	// Revoke deletes a token and prevents it from being used again. Any children
	// of the token are also revoked.
	Revoke(context.Context, *CredentialRevokeRequest) (*CredentialRevokeResponse, error)
	// contains filtered or unexported methods
}

CredentialServer is the server API for Credential service. All implementations must embed UnimplementedCredentialServer for forward compatibility

type LogClient 

type LogClient interface {
	// Create sets up a new log stream with a given context and name.
	Create(ctx context.Context, in *LogCreateRequest, opts ...grpc.CallOption) (*LogCreateResponse, error)
	// Delete removes access to an existing log stream. The log stream will no
	// longer be accessible to any client, although physical removal of data may
	// be delayed.
	Delete(ctx context.Context, in *LogDeleteRequest, opts ...grpc.CallOption) (*LogDeleteResponse, error)
	// List enumerates the log stream the authenticated credential has access to.
	List(ctx context.Context, in *LogListRequest, opts ...grpc.CallOption) (Log_ListClient, error)
	// MessageAppend adds a new message to the log stream. If the payload is
	// larger than 2MB, this RPC will return INVALID_ARGUMENT. If the service
	// needs to rate-limit this request, this RPC will return RESOURCE_EXHAUSTED
	// and additional information will be available in the QuotaFailure and
	// RetryInfo messages.
	MessageAppend(ctx context.Context, in *LogMessageAppendRequest, opts ...grpc.CallOption) (*LogMessageAppendResponse, error)
	// MessageList retrieves part or all of the messages in a log stream.
	// Messages are returned in the order received by the service.
	MessageList(ctx context.Context, in *LogMessageListRequest, opts ...grpc.CallOption) (Log_MessageListClient, error)
}

LogClient is the client API for Log 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 NewLogClient 

func NewLogClient(cc grpc.ClientConnInterface) LogClient

type LogCreateRequest 

type LogCreateRequest struct {

	// context for this log. It must be one of the contexts allowed for the
	// authenticated credential. If the credential only has access to one
	// context, this field is optional.
	Context string `protobuf:"bytes,1,opt,name=context,proto3" json:"context,omitempty"`
	// name is a human-readable identifier for the log stream in the provided
	// context like "stdout" or "info".
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*LogCreateRequest) Descriptor deprecated 

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

Deprecated: Use LogCreateRequest.ProtoReflect.Descriptor instead.

func (*LogCreateRequest) GetContext 

func (x *LogCreateRequest) GetContext() string

func (*LogCreateRequest) GetName 

func (x *LogCreateRequest) GetName() string

func (*LogCreateRequest) ProtoMessage 

func (*LogCreateRequest) ProtoMessage()

func (*LogCreateRequest) ProtoReflect 

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

func (*LogCreateRequest) Reset 

func (x *LogCreateRequest) Reset()

func (*LogCreateRequest) String 

func (x *LogCreateRequest) String() string

type LogCreateResponse 

type LogCreateResponse struct {

	// log_id is the unique identifier for the newly created log stream.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogCreateResponse) Descriptor deprecated 

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

Deprecated: Use LogCreateResponse.ProtoReflect.Descriptor instead.

func (*LogCreateResponse) GetLogId 

func (x *LogCreateResponse) GetLogId() string

func (*LogCreateResponse) ProtoMessage 

func (*LogCreateResponse) ProtoMessage()

func (*LogCreateResponse) ProtoReflect 

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

func (*LogCreateResponse) Reset 

func (x *LogCreateResponse) Reset()

func (*LogCreateResponse) String 

func (x *LogCreateResponse) String() string

type LogDeleteRequest 

type LogDeleteRequest struct {

	// log_id is the unique identifier for the log stream to delete.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogDeleteRequest) Descriptor deprecated 

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

Deprecated: Use LogDeleteRequest.ProtoReflect.Descriptor instead.

func (*LogDeleteRequest) GetLogId 

func (x *LogDeleteRequest) GetLogId() string

func (*LogDeleteRequest) ProtoMessage 

func (*LogDeleteRequest) ProtoMessage()

func (*LogDeleteRequest) ProtoReflect 

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

func (*LogDeleteRequest) Reset 

func (x *LogDeleteRequest) Reset()

func (*LogDeleteRequest) String 

func (x *LogDeleteRequest) String() string

type LogDeleteResponse 

type LogDeleteResponse struct {
	// contains filtered or unexported fields
}

func (*LogDeleteResponse) Descriptor deprecated 

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

Deprecated: Use LogDeleteResponse.ProtoReflect.Descriptor instead.

func (*LogDeleteResponse) ProtoMessage 

func (*LogDeleteResponse) ProtoMessage()

func (*LogDeleteResponse) ProtoReflect 

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

func (*LogDeleteResponse) Reset 

func (x *LogDeleteResponse) Reset()

func (*LogDeleteResponse) String 

func (x *LogDeleteResponse) String() string

type LogListRequest 

type LogListRequest struct {

	// contexts is an optional list of contexts to limit the response to. If not
	// specified, the response includes all contexts the authenticating
	// credential has access to.
	Contexts []string `protobuf:"bytes,1,rep,name=contexts,proto3" json:"contexts,omitempty"`
	// contains filtered or unexported fields
}

func (*LogListRequest) Descriptor deprecated 

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

Deprecated: Use LogListRequest.ProtoReflect.Descriptor instead.

func (*LogListRequest) GetContexts 

func (x *LogListRequest) GetContexts() []string

func (*LogListRequest) ProtoMessage 

func (*LogListRequest) ProtoMessage()

func (*LogListRequest) ProtoReflect 

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

func (*LogListRequest) Reset 

func (x *LogListRequest) Reset()

func (*LogListRequest) String 

func (x *LogListRequest) String() string

type LogListResponse 

type LogListResponse struct {

	// log_id is the unique identifier for the log stream.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// context for this log stream.
	Context string `protobuf:"bytes,2,opt,name=context,proto3" json:"context,omitempty"`
	// name is the human-readable identifier for this log stream.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*LogListResponse) Descriptor deprecated 

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

Deprecated: Use LogListResponse.ProtoReflect.Descriptor instead.

func (*LogListResponse) GetContext 

func (x *LogListResponse) GetContext() string

func (*LogListResponse) GetLogId 

func (x *LogListResponse) GetLogId() string

func (*LogListResponse) GetName 

func (x *LogListResponse) GetName() string

func (*LogListResponse) ProtoMessage 

func (*LogListResponse) ProtoMessage()

func (*LogListResponse) ProtoReflect 

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

func (*LogListResponse) Reset 

func (x *LogListResponse) Reset()

func (*LogListResponse) String 

func (x *LogListResponse) String() string

type LogMessageAppendRequest 

type LogMessageAppendRequest struct {

	// log_id is the identifier for the log stream to append to.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// media_type is the IANA media type for the payload. Initially, the only
	// supported media type is "application/octet-stream".
	MediaType string `protobuf:"bytes,2,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	// payload is the actual log data to append to the stream.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// timestamp is the time the message was originally received
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessageAppendRequest) Descriptor deprecated 

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

Deprecated: Use LogMessageAppendRequest.ProtoReflect.Descriptor instead.

func (*LogMessageAppendRequest) GetLogId 

func (x *LogMessageAppendRequest) GetLogId() string

func (*LogMessageAppendRequest) GetMediaType 

func (x *LogMessageAppendRequest) GetMediaType() string

func (*LogMessageAppendRequest) GetPayload 

func (x *LogMessageAppendRequest) GetPayload() []byte

func (*LogMessageAppendRequest) GetTimestamp 

func (x *LogMessageAppendRequest) GetTimestamp() *timestamppb.Timestamp

func (*LogMessageAppendRequest) ProtoMessage 

func (*LogMessageAppendRequest) ProtoMessage()

func (*LogMessageAppendRequest) ProtoReflect 

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

func (*LogMessageAppendRequest) Reset 

func (x *LogMessageAppendRequest) Reset()

func (*LogMessageAppendRequest) String 

func (x *LogMessageAppendRequest) String() string

type LogMessageAppendResponse 

type LogMessageAppendResponse struct {

	// log_id is the identifier for the log stream appended to.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// log_message_id is an opaque identifier for the message, unique to this log
	// stream.
	LogMessageId string `protobuf:"bytes,2,opt,name=log_message_id,json=logMessageId,proto3" json:"log_message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessageAppendResponse) Descriptor deprecated 

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

Deprecated: Use LogMessageAppendResponse.ProtoReflect.Descriptor instead.

func (*LogMessageAppendResponse) GetLogId 

func (x *LogMessageAppendResponse) GetLogId() string

func (*LogMessageAppendResponse) GetLogMessageId 

func (x *LogMessageAppendResponse) GetLogMessageId() string

func (*LogMessageAppendResponse) ProtoMessage 

func (*LogMessageAppendResponse) ProtoMessage()

func (*LogMessageAppendResponse) ProtoReflect 

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

func (*LogMessageAppendResponse) Reset 

func (x *LogMessageAppendResponse) Reset()

func (*LogMessageAppendResponse) String 

func (x *LogMessageAppendResponse) String() string

type LogMessageListRequest 

type LogMessageListRequest struct {

	// log_id is the identifier for the log stream to retrieve messages from.
	LogId string `protobuf:"bytes,1,opt,name=log_id,json=logId,proto3" json:"log_id,omitempty"`
	// follow indicates whether this request should stay open while new messages
	// are added to the stream. This method is opportunistic and the server may
	// cancel streaming at any time. The client may retry by issuing another list
	// request.
	Follow bool `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	// start_at is the offset to begin reading messages, inclusive.
	StartAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_at,json=startAt,proto3" json:"start_at,omitempty"`
	// end_at is the offset to stop reading messages, exclusive.
	EndAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_at,json=endAt,proto3" json:"end_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessageListRequest) Descriptor deprecated 

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

Deprecated: Use LogMessageListRequest.ProtoReflect.Descriptor instead.

func (*LogMessageListRequest) GetEndAt 

func (x *LogMessageListRequest) GetEndAt() *timestamppb.Timestamp

func (*LogMessageListRequest) GetFollow 

func (x *LogMessageListRequest) GetFollow() bool

func (*LogMessageListRequest) GetLogId 

func (x *LogMessageListRequest) GetLogId() string

func (*LogMessageListRequest) GetStartAt 

func (x *LogMessageListRequest) GetStartAt() *timestamppb.Timestamp

func (*LogMessageListRequest) ProtoMessage 

func (*LogMessageListRequest) ProtoMessage()

func (*LogMessageListRequest) ProtoReflect 

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

func (*LogMessageListRequest) Reset 

func (x *LogMessageListRequest) Reset()

func (*LogMessageListRequest) String 

func (x *LogMessageListRequest) String() string

type LogMessageListResponse 

type LogMessageListResponse struct {

	// log_message_id is the stream-unique identifier for this message.
	LogMessageId string `protobuf:"bytes,1,opt,name=log_message_id,json=logMessageId,proto3" json:"log_message_id,omitempty"`
	// media_type is the IANA media type for the payload.
	MediaType string `protobuf:"bytes,2,opt,name=media_type,json=mediaType,proto3" json:"media_type,omitempty"`
	// payload is the actual log data.
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// timestamp is the time the message was originally received
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogMessageListResponse) Descriptor deprecated 

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

Deprecated: Use LogMessageListResponse.ProtoReflect.Descriptor instead.

func (*LogMessageListResponse) GetLogMessageId 

func (x *LogMessageListResponse) GetLogMessageId() string

func (*LogMessageListResponse) GetMediaType 

func (x *LogMessageListResponse) GetMediaType() string

func (*LogMessageListResponse) GetPayload 

func (x *LogMessageListResponse) GetPayload() []byte

func (*LogMessageListResponse) GetTimestamp 

func (x *LogMessageListResponse) GetTimestamp() *timestamppb.Timestamp

func (*LogMessageListResponse) ProtoMessage 

func (*LogMessageListResponse) ProtoMessage()

func (*LogMessageListResponse) ProtoReflect 

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

func (*LogMessageListResponse) Reset 

func (x *LogMessageListResponse) Reset()

func (*LogMessageListResponse) String 

func (x *LogMessageListResponse) String() string

type LogServer 

type LogServer interface {
	// Create sets up a new log stream with a given context and name.
	Create(context.Context, *LogCreateRequest) (*LogCreateResponse, error)
	// Delete removes access to an existing log stream. The log stream will no
	// longer be accessible to any client, although physical removal of data may
	// be delayed.
	Delete(context.Context, *LogDeleteRequest) (*LogDeleteResponse, error)
	// List enumerates the log stream the authenticated credential has access to.
	List(*LogListRequest, Log_ListServer) error
	// MessageAppend adds a new message to the log stream. If the payload is
	// larger than 2MB, this RPC will return INVALID_ARGUMENT. If the service
	// needs to rate-limit this request, this RPC will return RESOURCE_EXHAUSTED
	// and additional information will be available in the QuotaFailure and
	// RetryInfo messages.
	MessageAppend(context.Context, *LogMessageAppendRequest) (*LogMessageAppendResponse, error)
	// MessageList retrieves part or all of the messages in a log stream.
	// Messages are returned in the order received by the service.
	MessageList(*LogMessageListRequest, Log_MessageListServer) error
	// contains filtered or unexported methods
}

LogServer is the server API for Log service. All implementations must embed UnimplementedLogServer for forward compatibility

type Log_ListClient 

type Log_ListClient interface {
	Recv() (*LogListResponse, error)
	grpc.ClientStream
}

type Log_ListServer 

type Log_ListServer interface {
	Send(*LogListResponse) error
	grpc.ServerStream
}

type Log_MessageListClient 

type Log_MessageListClient interface {
	Recv() (*LogMessageListResponse, error)
	grpc.ClientStream
}

type Log_MessageListServer 

type Log_MessageListServer interface {
	Send(*LogMessageListResponse) error
	grpc.ServerStream
}

type UnimplementedCredentialServer 

type UnimplementedCredentialServer struct {
}

UnimplementedCredentialServer must be embedded to have forward compatible implementations.

func (UnimplementedCredentialServer) Issue 

func (UnimplementedCredentialServer) Issue(context.Context, *CredentialIssueRequest) (*CredentialIssueResponse, error)

func (UnimplementedCredentialServer) Refresh 

func (UnimplementedCredentialServer) Refresh(context.Context, *CredentialRefreshRequest) (*CredentialRefreshResponse, error)

func (UnimplementedCredentialServer) Revoke 

func (UnimplementedCredentialServer) Revoke(context.Context, *CredentialRevokeRequest) (*CredentialRevokeResponse, error)

type UnimplementedLogServer 

type UnimplementedLogServer struct {
}

UnimplementedLogServer must be embedded to have forward compatible implementations.

func (UnimplementedLogServer) Create 

func (UnimplementedLogServer) Create(context.Context, *LogCreateRequest) (*LogCreateResponse, error)

func (UnimplementedLogServer) Delete 

func (UnimplementedLogServer) Delete(context.Context, *LogDeleteRequest) (*LogDeleteResponse, error)

func (UnimplementedLogServer) List 

func (UnimplementedLogServer) List(*LogListRequest, Log_ListServer) error

func (UnimplementedLogServer) MessageAppend 

func (UnimplementedLogServer) MessageAppend(context.Context, *LogMessageAppendRequest) (*LogMessageAppendResponse, error)

func (UnimplementedLogServer) MessageList 

func (UnimplementedLogServer) MessageList(*LogMessageListRequest, Log_MessageListServer) error

type UnsafeCredentialServer 

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

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

type UnsafeLogServer 

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

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

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.