bucket_client

package
v1.0.28 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2024 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchGetBucketsDescriptor 

type BatchGetBucketsDescriptor struct{}

func GetBatchGetBucketsDescriptor 

func GetBatchGetBucketsDescriptor() *BatchGetBucketsDescriptor

func (*BatchGetBucketsDescriptor) GetApiDescriptor 

func (d *BatchGetBucketsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*BatchGetBucketsDescriptor) GetApiName 

func (d *BatchGetBucketsDescriptor) GetApiName() string

func (*BatchGetBucketsDescriptor) GetClientMsgReflectHandle 

func (d *BatchGetBucketsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*BatchGetBucketsDescriptor) GetFullMethodName 

func (d *BatchGetBucketsDescriptor) GetFullMethodName() string

func (*BatchGetBucketsDescriptor) GetMethodName 

func (d *BatchGetBucketsDescriptor) GetMethodName() string

func (*BatchGetBucketsDescriptor) GetProtoPkgName 

func (d *BatchGetBucketsDescriptor) GetProtoPkgName() string

func (*BatchGetBucketsDescriptor) GetResourceDescriptor 

func (d *BatchGetBucketsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*BatchGetBucketsDescriptor) GetServerMsgReflectHandle 

func (d *BatchGetBucketsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*BatchGetBucketsDescriptor) GetServiceDomain 

func (d *BatchGetBucketsDescriptor) GetServiceDomain() string

func (*BatchGetBucketsDescriptor) GetServiceVersion 

func (d *BatchGetBucketsDescriptor) GetServiceVersion() string

func (*BatchGetBucketsDescriptor) GetVerb 

func (d *BatchGetBucketsDescriptor) GetVerb() string

func (*BatchGetBucketsDescriptor) HasResource 

func (d *BatchGetBucketsDescriptor) HasResource() bool

func (*BatchGetBucketsDescriptor) IsClientStream 

func (d *BatchGetBucketsDescriptor) IsClientStream() bool

func (*BatchGetBucketsDescriptor) IsCollection 

func (d *BatchGetBucketsDescriptor) IsCollection() bool

func (*BatchGetBucketsDescriptor) IsPlural 

func (d *BatchGetBucketsDescriptor) IsPlural() bool

func (*BatchGetBucketsDescriptor) IsServerStream 

func (d *BatchGetBucketsDescriptor) IsServerStream() bool

func (*BatchGetBucketsDescriptor) IsUnary 

func (d *BatchGetBucketsDescriptor) IsUnary() bool

func (*BatchGetBucketsDescriptor) NewEmptyClientMsg 

func (d *BatchGetBucketsDescriptor) NewEmptyClientMsg() proto.Message

func (*BatchGetBucketsDescriptor) NewEmptyServerMsg 

func (d *BatchGetBucketsDescriptor) NewEmptyServerMsg() proto.Message

func (*BatchGetBucketsDescriptor) RequestHasResourceBody 

func (d *BatchGetBucketsDescriptor) RequestHasResourceBody() bool

type BatchGetBucketsDescriptorClientMsgHandle 

type BatchGetBucketsDescriptorClientMsgHandle struct{}

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractCollectionName 

func (h *BatchGetBucketsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBody 

func (h *BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceName 

func (h *BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceNames 

func (h *BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type BatchGetBucketsDescriptorServerMsgHandle 

type BatchGetBucketsDescriptorServerMsgHandle struct{}

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractCollectionName 

func (h *BatchGetBucketsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBody 

func (h *BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceName 

func (h *BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceNames 

func (h *BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type BatchGetBucketsRequest 

type BatchGetBucketsRequest struct {

	// Names of Buckets
	Names []*bucket.Name `protobuf:"bytes,2,rep,customtype=Name,name=names,proto3" json:"names,omitempty" firestore:"names"`
	// A list of extra fields to be obtained for each response item on top of
	// fields defined by request field view
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [BatchGetBuckets][ntt.logging.v1.BatchGetBuckets]

func (*BatchGetBucketsRequest) Descriptor 

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

Deprecated, Use BatchGetBucketsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetBucketsRequest) GetFieldMask 

func (m *BatchGetBucketsRequest) GetFieldMask() *bucket.Bucket_FieldMask

func (*BatchGetBucketsRequest) GetNames 

func (m *BatchGetBucketsRequest) GetNames() []*bucket.Name

func (*BatchGetBucketsRequest) GetView 

func (m *BatchGetBucketsRequest) GetView() view.View

func (*BatchGetBucketsRequest) GotenMessage 

func (*BatchGetBucketsRequest) GotenMessage()

func (*BatchGetBucketsRequest) GotenValidate 

func (obj *BatchGetBucketsRequest) GotenValidate() error

func (*BatchGetBucketsRequest) Marshal 

func (m *BatchGetBucketsRequest) Marshal() ([]byte, error)

func (*BatchGetBucketsRequest) MarshalJSON 

func (m *BatchGetBucketsRequest) MarshalJSON() ([]byte, error)

func (*BatchGetBucketsRequest) ProtoMessage 

func (*BatchGetBucketsRequest) ProtoMessage()

func (*BatchGetBucketsRequest) ProtoReflect 

func (m *BatchGetBucketsRequest) ProtoReflect() preflect.Message

func (*BatchGetBucketsRequest) Reset 

func (m *BatchGetBucketsRequest) Reset()

func (*BatchGetBucketsRequest) SetFieldMask 

func (m *BatchGetBucketsRequest) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*BatchGetBucketsRequest) SetNames 

func (m *BatchGetBucketsRequest) SetNames(fv []*bucket.Name)

func (*BatchGetBucketsRequest) SetView 

func (m *BatchGetBucketsRequest) SetView(fv view.View)

func (*BatchGetBucketsRequest) String 

func (m *BatchGetBucketsRequest) String() string

func (*BatchGetBucketsRequest) Unmarshal 

func (m *BatchGetBucketsRequest) Unmarshal(b []byte) error

func (*BatchGetBucketsRequest) UnmarshalJSON 

func (m *BatchGetBucketsRequest) UnmarshalJSON(data []byte) error

type BatchGetBucketsResponse 

type BatchGetBucketsResponse struct {

	// found Buckets
	Buckets []*bucket.Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty" firestore:"buckets"`
	// list of not found Buckets
	Missing []*bucket.Name `protobuf:"bytes,2,rep,customtype=Name,name=missing,proto3" json:"missing,omitempty" firestore:"missing"`
	// contains filtered or unexported fields
}

BatchGetBucketsResponse

func (*BatchGetBucketsResponse) Descriptor 

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

Deprecated, Use BatchGetBucketsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetBucketsResponse) GetBuckets 

func (m *BatchGetBucketsResponse) GetBuckets() []*bucket.Bucket

func (*BatchGetBucketsResponse) GetMissing 

func (m *BatchGetBucketsResponse) GetMissing() []*bucket.Name

func (*BatchGetBucketsResponse) GotenMessage 

func (*BatchGetBucketsResponse) GotenMessage()

func (*BatchGetBucketsResponse) GotenValidate 

func (obj *BatchGetBucketsResponse) GotenValidate() error

func (*BatchGetBucketsResponse) Marshal 

func (m *BatchGetBucketsResponse) Marshal() ([]byte, error)

func (*BatchGetBucketsResponse) MarshalJSON 

func (m *BatchGetBucketsResponse) MarshalJSON() ([]byte, error)

func (*BatchGetBucketsResponse) ProtoMessage 

func (*BatchGetBucketsResponse) ProtoMessage()

func (*BatchGetBucketsResponse) ProtoReflect 

func (m *BatchGetBucketsResponse) ProtoReflect() preflect.Message

func (*BatchGetBucketsResponse) Reset 

func (m *BatchGetBucketsResponse) Reset()

func (*BatchGetBucketsResponse) SetBuckets 

func (m *BatchGetBucketsResponse) SetBuckets(fv []*bucket.Bucket)

func (*BatchGetBucketsResponse) SetMissing 

func (m *BatchGetBucketsResponse) SetMissing(fv []*bucket.Name)

func (*BatchGetBucketsResponse) String 

func (m *BatchGetBucketsResponse) String() string

func (*BatchGetBucketsResponse) Unmarshal 

func (m *BatchGetBucketsResponse) Unmarshal(b []byte) error

func (*BatchGetBucketsResponse) UnmarshalJSON 

func (m *BatchGetBucketsResponse) UnmarshalJSON(data []byte) error

type BucketServiceClient 

type BucketServiceClient interface {
	GetBucket(ctx context.Context, in *GetBucketRequest, opts ...grpc.CallOption) (*bucket.Bucket, error)
	BatchGetBuckets(ctx context.Context, in *BatchGetBucketsRequest, opts ...grpc.CallOption) (*BatchGetBucketsResponse, error)
	ListBuckets(ctx context.Context, in *ListBucketsRequest, opts ...grpc.CallOption) (*ListBucketsResponse, error)
	WatchBucket(ctx context.Context, in *WatchBucketRequest, opts ...grpc.CallOption) (WatchBucketClientStream, error)
	WatchBuckets(ctx context.Context, in *WatchBucketsRequest, opts ...grpc.CallOption) (WatchBucketsClientStream, error)
	CreateBucket(ctx context.Context, in *CreateBucketRequest, opts ...grpc.CallOption) (*bucket.Bucket, error)
	UpdateBucket(ctx context.Context, in *UpdateBucketRequest, opts ...grpc.CallOption) (*bucket.Bucket, error)
	DeleteBucket(ctx context.Context, in *DeleteBucketRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

BucketServiceClient is the client API for BucketService.

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

func NewBucketServiceClient 

func NewBucketServiceClient(cc grpc.ClientConnInterface) BucketServiceClient

type BucketServiceDescriptor 

type BucketServiceDescriptor struct{}

func GetBucketServiceDescriptor 

func GetBucketServiceDescriptor() *BucketServiceDescriptor

func (*BucketServiceDescriptor) AllMethodDescriptors 

func (d *BucketServiceDescriptor) AllMethodDescriptors() []gotenclient.MethodDescriptor

func (*BucketServiceDescriptor) GetApiName 

func (d *BucketServiceDescriptor) GetApiName() string

func (*BucketServiceDescriptor) GetFullAPIName 

func (d *BucketServiceDescriptor) GetFullAPIName() string

func (*BucketServiceDescriptor) GetProtoPkgName 

func (d *BucketServiceDescriptor) GetProtoPkgName() string

func (*BucketServiceDescriptor) GetServiceDomain 

func (d *BucketServiceDescriptor) GetServiceDomain() string

func (*BucketServiceDescriptor) GetServiceVersion 

func (d *BucketServiceDescriptor) GetServiceVersion() string

type CreateBucketDescriptor 

type CreateBucketDescriptor struct{}

func GetCreateBucketDescriptor 

func GetCreateBucketDescriptor() *CreateBucketDescriptor

func (*CreateBucketDescriptor) GetApiDescriptor 

func (d *CreateBucketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*CreateBucketDescriptor) GetApiName 

func (d *CreateBucketDescriptor) GetApiName() string

func (*CreateBucketDescriptor) GetClientMsgReflectHandle 

func (d *CreateBucketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*CreateBucketDescriptor) GetFullMethodName 

func (d *CreateBucketDescriptor) GetFullMethodName() string

func (*CreateBucketDescriptor) GetMethodName 

func (d *CreateBucketDescriptor) GetMethodName() string

func (*CreateBucketDescriptor) GetProtoPkgName 

func (d *CreateBucketDescriptor) GetProtoPkgName() string

func (*CreateBucketDescriptor) GetResourceDescriptor 

func (d *CreateBucketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*CreateBucketDescriptor) GetServerMsgReflectHandle 

func (d *CreateBucketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*CreateBucketDescriptor) GetServiceDomain 

func (d *CreateBucketDescriptor) GetServiceDomain() string

func (*CreateBucketDescriptor) GetServiceVersion 

func (d *CreateBucketDescriptor) GetServiceVersion() string

func (*CreateBucketDescriptor) GetVerb 

func (d *CreateBucketDescriptor) GetVerb() string

func (*CreateBucketDescriptor) HasResource 

func (d *CreateBucketDescriptor) HasResource() bool

func (*CreateBucketDescriptor) IsClientStream 

func (d *CreateBucketDescriptor) IsClientStream() bool

func (*CreateBucketDescriptor) IsCollection 

func (d *CreateBucketDescriptor) IsCollection() bool

func (*CreateBucketDescriptor) IsPlural 

func (d *CreateBucketDescriptor) IsPlural() bool

func (*CreateBucketDescriptor) IsServerStream 

func (d *CreateBucketDescriptor) IsServerStream() bool

func (*CreateBucketDescriptor) IsUnary 

func (d *CreateBucketDescriptor) IsUnary() bool

func (*CreateBucketDescriptor) NewEmptyClientMsg 

func (d *CreateBucketDescriptor) NewEmptyClientMsg() proto.Message

func (*CreateBucketDescriptor) NewEmptyServerMsg 

func (d *CreateBucketDescriptor) NewEmptyServerMsg() proto.Message

func (*CreateBucketDescriptor) RequestHasResourceBody 

func (d *CreateBucketDescriptor) RequestHasResourceBody() bool

type CreateBucketDescriptorClientMsgHandle 

type CreateBucketDescriptorClientMsgHandle struct{}

func (*CreateBucketDescriptorClientMsgHandle) ExtractCollectionName 

func (h *CreateBucketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *CreateBucketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceBody 

func (h *CreateBucketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceName 

func (h *CreateBucketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceNames 

func (h *CreateBucketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type CreateBucketDescriptorServerMsgHandle 

type CreateBucketDescriptorServerMsgHandle struct{}

func (*CreateBucketDescriptorServerMsgHandle) ExtractCollectionName 

func (h *CreateBucketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *CreateBucketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceBody 

func (h *CreateBucketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceName 

func (h *CreateBucketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceNames 

func (h *CreateBucketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type CreateBucketRequest 

type CreateBucketRequest struct {

	// Parent name of ntt.logging.v1.Bucket
	Parent *bucket.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Bucket resource body
	Bucket *bucket.Bucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty" firestore:"bucket"`
	// contains filtered or unexported fields
}

Request message for method [CreateBucket][ntt.logging.v1.CreateBucket]

func (*CreateBucketRequest) Descriptor 

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

Deprecated, Use CreateBucketRequest.ProtoReflect.Descriptor instead.

func (*CreateBucketRequest) GetBucket 

func (m *CreateBucketRequest) GetBucket() *bucket.Bucket

func (*CreateBucketRequest) GetParent 

func (m *CreateBucketRequest) GetParent() *bucket.ParentName

func (*CreateBucketRequest) GotenMessage 

func (*CreateBucketRequest) GotenMessage()

func (*CreateBucketRequest) GotenValidate 

func (obj *CreateBucketRequest) GotenValidate() error

func (*CreateBucketRequest) Marshal 

func (m *CreateBucketRequest) Marshal() ([]byte, error)

func (*CreateBucketRequest) MarshalJSON 

func (m *CreateBucketRequest) MarshalJSON() ([]byte, error)

func (*CreateBucketRequest) ProtoMessage 

func (*CreateBucketRequest) ProtoMessage()

func (*CreateBucketRequest) ProtoReflect 

func (m *CreateBucketRequest) ProtoReflect() preflect.Message

func (*CreateBucketRequest) Reset 

func (m *CreateBucketRequest) Reset()

func (*CreateBucketRequest) SetBucket 

func (m *CreateBucketRequest) SetBucket(fv *bucket.Bucket)

func (*CreateBucketRequest) SetParent 

func (m *CreateBucketRequest) SetParent(fv *bucket.ParentName)

func (*CreateBucketRequest) String 

func (m *CreateBucketRequest) String() string

func (*CreateBucketRequest) Unmarshal 

func (m *CreateBucketRequest) Unmarshal(b []byte) error

func (*CreateBucketRequest) UnmarshalJSON 

func (m *CreateBucketRequest) UnmarshalJSON(data []byte) error

type DeleteBucketDescriptor 

type DeleteBucketDescriptor struct{}

func GetDeleteBucketDescriptor 

func GetDeleteBucketDescriptor() *DeleteBucketDescriptor

func (*DeleteBucketDescriptor) GetApiDescriptor 

func (d *DeleteBucketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*DeleteBucketDescriptor) GetApiName 

func (d *DeleteBucketDescriptor) GetApiName() string

func (*DeleteBucketDescriptor) GetClientMsgReflectHandle 

func (d *DeleteBucketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*DeleteBucketDescriptor) GetFullMethodName 

func (d *DeleteBucketDescriptor) GetFullMethodName() string

func (*DeleteBucketDescriptor) GetMethodName 

func (d *DeleteBucketDescriptor) GetMethodName() string

func (*DeleteBucketDescriptor) GetProtoPkgName 

func (d *DeleteBucketDescriptor) GetProtoPkgName() string

func (*DeleteBucketDescriptor) GetResourceDescriptor 

func (d *DeleteBucketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*DeleteBucketDescriptor) GetServerMsgReflectHandle 

func (d *DeleteBucketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*DeleteBucketDescriptor) GetServiceDomain 

func (d *DeleteBucketDescriptor) GetServiceDomain() string

func (*DeleteBucketDescriptor) GetServiceVersion 

func (d *DeleteBucketDescriptor) GetServiceVersion() string

func (*DeleteBucketDescriptor) GetVerb 

func (d *DeleteBucketDescriptor) GetVerb() string

func (*DeleteBucketDescriptor) HasResource 

func (d *DeleteBucketDescriptor) HasResource() bool

func (*DeleteBucketDescriptor) IsClientStream 

func (d *DeleteBucketDescriptor) IsClientStream() bool

func (*DeleteBucketDescriptor) IsCollection 

func (d *DeleteBucketDescriptor) IsCollection() bool

func (*DeleteBucketDescriptor) IsPlural 

func (d *DeleteBucketDescriptor) IsPlural() bool

func (*DeleteBucketDescriptor) IsServerStream 

func (d *DeleteBucketDescriptor) IsServerStream() bool

func (*DeleteBucketDescriptor) IsUnary 

func (d *DeleteBucketDescriptor) IsUnary() bool

func (*DeleteBucketDescriptor) NewEmptyClientMsg 

func (d *DeleteBucketDescriptor) NewEmptyClientMsg() proto.Message

func (*DeleteBucketDescriptor) NewEmptyServerMsg 

func (d *DeleteBucketDescriptor) NewEmptyServerMsg() proto.Message

func (*DeleteBucketDescriptor) RequestHasResourceBody 

func (d *DeleteBucketDescriptor) RequestHasResourceBody() bool

type DeleteBucketDescriptorClientMsgHandle 

type DeleteBucketDescriptorClientMsgHandle struct{}

func (*DeleteBucketDescriptorClientMsgHandle) ExtractCollectionName 

func (h *DeleteBucketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *DeleteBucketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceBody 

func (h *DeleteBucketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceName 

func (h *DeleteBucketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceNames 

func (h *DeleteBucketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type DeleteBucketDescriptorServerMsgHandle 

type DeleteBucketDescriptorServerMsgHandle struct{}

func (*DeleteBucketDescriptorServerMsgHandle) ExtractCollectionName 

func (h *DeleteBucketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *DeleteBucketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceBody 

func (h *DeleteBucketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceName 

func (h *DeleteBucketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceNames 

func (h *DeleteBucketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type DeleteBucketRequest 

type DeleteBucketRequest struct {

	// Name of ntt.logging.v1.Bucket
	Name *bucket.Name `protobuf:"bytes,1,opt,customtype=Name,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// contains filtered or unexported fields
}

Request message for method [DeleteBucket][ntt.logging.v1.DeleteBucket]

func (*DeleteBucketRequest) Descriptor 

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

Deprecated, Use DeleteBucketRequest.ProtoReflect.Descriptor instead.

func (*DeleteBucketRequest) GetName 

func (m *DeleteBucketRequest) GetName() *bucket.Name

func (*DeleteBucketRequest) GotenMessage 

func (*DeleteBucketRequest) GotenMessage()

func (*DeleteBucketRequest) GotenValidate 

func (obj *DeleteBucketRequest) GotenValidate() error

func (*DeleteBucketRequest) Marshal 

func (m *DeleteBucketRequest) Marshal() ([]byte, error)

func (*DeleteBucketRequest) MarshalJSON 

func (m *DeleteBucketRequest) MarshalJSON() ([]byte, error)

func (*DeleteBucketRequest) ProtoMessage 

func (*DeleteBucketRequest) ProtoMessage()

func (*DeleteBucketRequest) ProtoReflect 

func (m *DeleteBucketRequest) ProtoReflect() preflect.Message

func (*DeleteBucketRequest) Reset 

func (m *DeleteBucketRequest) Reset()

func (*DeleteBucketRequest) SetName 

func (m *DeleteBucketRequest) SetName(fv *bucket.Name)

func (*DeleteBucketRequest) String 

func (m *DeleteBucketRequest) String() string

func (*DeleteBucketRequest) Unmarshal 

func (m *DeleteBucketRequest) Unmarshal(b []byte) error

func (*DeleteBucketRequest) UnmarshalJSON 

func (m *DeleteBucketRequest) UnmarshalJSON(data []byte) error

type GetBucketDescriptor 

type GetBucketDescriptor struct{}

func GetGetBucketDescriptor 

func GetGetBucketDescriptor() *GetBucketDescriptor

func (*GetBucketDescriptor) GetApiDescriptor 

func (d *GetBucketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*GetBucketDescriptor) GetApiName 

func (d *GetBucketDescriptor) GetApiName() string

func (*GetBucketDescriptor) GetClientMsgReflectHandle 

func (d *GetBucketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*GetBucketDescriptor) GetFullMethodName 

func (d *GetBucketDescriptor) GetFullMethodName() string

func (*GetBucketDescriptor) GetMethodName 

func (d *GetBucketDescriptor) GetMethodName() string

func (*GetBucketDescriptor) GetProtoPkgName 

func (d *GetBucketDescriptor) GetProtoPkgName() string

func (*GetBucketDescriptor) GetResourceDescriptor 

func (d *GetBucketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*GetBucketDescriptor) GetServerMsgReflectHandle 

func (d *GetBucketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*GetBucketDescriptor) GetServiceDomain 

func (d *GetBucketDescriptor) GetServiceDomain() string

func (*GetBucketDescriptor) GetServiceVersion 

func (d *GetBucketDescriptor) GetServiceVersion() string

func (*GetBucketDescriptor) GetVerb 

func (d *GetBucketDescriptor) GetVerb() string

func (*GetBucketDescriptor) HasResource 

func (d *GetBucketDescriptor) HasResource() bool

func (*GetBucketDescriptor) IsClientStream 

func (d *GetBucketDescriptor) IsClientStream() bool

func (*GetBucketDescriptor) IsCollection 

func (d *GetBucketDescriptor) IsCollection() bool

func (*GetBucketDescriptor) IsPlural 

func (d *GetBucketDescriptor) IsPlural() bool

func (*GetBucketDescriptor) IsServerStream 

func (d *GetBucketDescriptor) IsServerStream() bool

func (*GetBucketDescriptor) IsUnary 

func (d *GetBucketDescriptor) IsUnary() bool

func (*GetBucketDescriptor) NewEmptyClientMsg 

func (d *GetBucketDescriptor) NewEmptyClientMsg() proto.Message

func (*GetBucketDescriptor) NewEmptyServerMsg 

func (d *GetBucketDescriptor) NewEmptyServerMsg() proto.Message

func (*GetBucketDescriptor) RequestHasResourceBody 

func (d *GetBucketDescriptor) RequestHasResourceBody() bool

type GetBucketDescriptorClientMsgHandle 

type GetBucketDescriptorClientMsgHandle struct{}

func (*GetBucketDescriptorClientMsgHandle) ExtractCollectionName 

func (h *GetBucketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *GetBucketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceBody 

func (h *GetBucketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceName 

func (h *GetBucketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceNames 

func (h *GetBucketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type GetBucketDescriptorServerMsgHandle 

type GetBucketDescriptorServerMsgHandle struct{}

func (*GetBucketDescriptorServerMsgHandle) ExtractCollectionName 

func (h *GetBucketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *GetBucketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceBody 

func (h *GetBucketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceName 

func (h *GetBucketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceNames 

func (h *GetBucketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type GetBucketRequest 

type GetBucketRequest struct {

	// Name of ntt.logging.v1.Bucket
	Name *bucket.Name `protobuf:"bytes,1,opt,customtype=Name,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// A list of extra fields to be obtained for each response item on top of
	// fields defined by request field view
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [GetBucket][ntt.logging.v1.GetBucket]

func (*GetBucketRequest) Descriptor 

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

Deprecated, Use GetBucketRequest.ProtoReflect.Descriptor instead.

func (*GetBucketRequest) GetFieldMask 

func (m *GetBucketRequest) GetFieldMask() *bucket.Bucket_FieldMask

func (*GetBucketRequest) GetName 

func (m *GetBucketRequest) GetName() *bucket.Name

func (*GetBucketRequest) GetView 

func (m *GetBucketRequest) GetView() view.View

func (*GetBucketRequest) GotenMessage 

func (*GetBucketRequest) GotenMessage()

func (*GetBucketRequest) GotenValidate 

func (obj *GetBucketRequest) GotenValidate() error

func (*GetBucketRequest) Marshal 

func (m *GetBucketRequest) Marshal() ([]byte, error)

func (*GetBucketRequest) MarshalJSON 

func (m *GetBucketRequest) MarshalJSON() ([]byte, error)

func (*GetBucketRequest) ProtoMessage 

func (*GetBucketRequest) ProtoMessage()

func (*GetBucketRequest) ProtoReflect 

func (m *GetBucketRequest) ProtoReflect() preflect.Message

func (*GetBucketRequest) Reset 

func (m *GetBucketRequest) Reset()

func (*GetBucketRequest) SetFieldMask 

func (m *GetBucketRequest) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*GetBucketRequest) SetName 

func (m *GetBucketRequest) SetName(fv *bucket.Name)

func (*GetBucketRequest) SetView 

func (m *GetBucketRequest) SetView(fv view.View)

func (*GetBucketRequest) String 

func (m *GetBucketRequest) String() string

func (*GetBucketRequest) Unmarshal 

func (m *GetBucketRequest) Unmarshal(b []byte) error

func (*GetBucketRequest) UnmarshalJSON 

func (m *GetBucketRequest) UnmarshalJSON(data []byte) error

type ListBucketsDescriptor 

type ListBucketsDescriptor struct{}

func GetListBucketsDescriptor 

func GetListBucketsDescriptor() *ListBucketsDescriptor

func (*ListBucketsDescriptor) GetApiDescriptor 

func (d *ListBucketsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*ListBucketsDescriptor) GetApiName 

func (d *ListBucketsDescriptor) GetApiName() string

func (*ListBucketsDescriptor) GetClientMsgReflectHandle 

func (d *ListBucketsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListBucketsDescriptor) GetFullMethodName 

func (d *ListBucketsDescriptor) GetFullMethodName() string

func (*ListBucketsDescriptor) GetMethodName 

func (d *ListBucketsDescriptor) GetMethodName() string

func (*ListBucketsDescriptor) GetProtoPkgName 

func (d *ListBucketsDescriptor) GetProtoPkgName() string

func (*ListBucketsDescriptor) GetResourceDescriptor 

func (d *ListBucketsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*ListBucketsDescriptor) GetServerMsgReflectHandle 

func (d *ListBucketsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*ListBucketsDescriptor) GetServiceDomain 

func (d *ListBucketsDescriptor) GetServiceDomain() string

func (*ListBucketsDescriptor) GetServiceVersion 

func (d *ListBucketsDescriptor) GetServiceVersion() string

func (*ListBucketsDescriptor) GetVerb 

func (d *ListBucketsDescriptor) GetVerb() string

func (*ListBucketsDescriptor) HasResource 

func (d *ListBucketsDescriptor) HasResource() bool

func (*ListBucketsDescriptor) IsClientStream 

func (d *ListBucketsDescriptor) IsClientStream() bool

func (*ListBucketsDescriptor) IsCollection 

func (d *ListBucketsDescriptor) IsCollection() bool

func (*ListBucketsDescriptor) IsPlural 

func (d *ListBucketsDescriptor) IsPlural() bool

func (*ListBucketsDescriptor) IsServerStream 

func (d *ListBucketsDescriptor) IsServerStream() bool

func (*ListBucketsDescriptor) IsUnary 

func (d *ListBucketsDescriptor) IsUnary() bool

func (*ListBucketsDescriptor) NewEmptyClientMsg 

func (d *ListBucketsDescriptor) NewEmptyClientMsg() proto.Message

func (*ListBucketsDescriptor) NewEmptyServerMsg 

func (d *ListBucketsDescriptor) NewEmptyServerMsg() proto.Message

func (*ListBucketsDescriptor) RequestHasResourceBody 

func (d *ListBucketsDescriptor) RequestHasResourceBody() bool

type ListBucketsDescriptorClientMsgHandle 

type ListBucketsDescriptorClientMsgHandle struct{}

func (*ListBucketsDescriptorClientMsgHandle) ExtractCollectionName 

func (h *ListBucketsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *ListBucketsDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceBody 

func (h *ListBucketsDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceName 

func (h *ListBucketsDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceNames 

func (h *ListBucketsDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type ListBucketsDescriptorServerMsgHandle 

type ListBucketsDescriptorServerMsgHandle struct{}

func (*ListBucketsDescriptorServerMsgHandle) ExtractCollectionName 

func (h *ListBucketsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *ListBucketsDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceBody 

func (h *ListBucketsDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceName 

func (h *ListBucketsDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceNames 

func (h *ListBucketsDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type ListBucketsRequest 

type ListBucketsRequest struct {

	// Parent name of ntt.logging.v1.Bucket
	Parent *bucket.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Buckets than requested.
	// If unspecified, server will pick an appropriate default.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty" firestore:"pageSize"`
	// A token identifying a page of results the server should return.
	// Typically, this is the value of
	// [ListBucketsResponse.next_page_token][ntt.logging.v1.ListBucketsResponse.next_page_token]
	PageToken *bucket.PagerCursor `` /* 133-byte string literal not displayed */
	// Order By -
	// https://cloud.google.com/apis/design/design_patterns#list_pagination list
	// of field path with order directive, either 'asc' or 'desc'. If direction is
	// not provided, 'asc' is assumed. e.g. "state.nested_field asc,
	// state.something.else desc, theme"
	OrderBy *bucket.OrderBy `protobuf:"bytes,4,opt,customtype=OrderBy,name=order_by,json=orderBy,proto3" json:"order_by,omitempty" firestore:"orderBy"`
	// Filter - filter results by field criteria. Simplified SQL-like syntax with
	// following operators:
	// <=, >=, =, !=, <, >, LIKE, CONTAINS (aliases CONTAIN, HAS, HAVE), IN, IS
	// [NOT] NULL | NaN . Combine conditions with OR | AND example: 'meta.labels
	// CONTAINS "severity:important" OR (state.last_error_time >
	// "2018-11-15T10:00:00Z" AND state.status = "ERROR")'
	Filter *bucket.Filter `protobuf:"bytes,5,opt,customtype=Filter,name=filter,proto3" json:"filter,omitempty" firestore:"filter"`
	// A list of extra fields to be obtained for each response item on top of
	// fields defined by request field view
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,7,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// Indicates if list response should contain total count and offset (fields
	// current_offset and total_results_count).
	IncludePagingInfo bool `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [ListBuckets][ntt.logging.v1.ListBuckets]

func (*ListBucketsRequest) Descriptor 

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

Deprecated, Use ListBucketsRequest.ProtoReflect.Descriptor instead.

func (*ListBucketsRequest) GetFieldMask 

func (m *ListBucketsRequest) GetFieldMask() *bucket.Bucket_FieldMask

func (*ListBucketsRequest) GetFilter 

func (m *ListBucketsRequest) GetFilter() *bucket.Filter

func (*ListBucketsRequest) GetIncludePagingInfo 

func (m *ListBucketsRequest) GetIncludePagingInfo() bool

func (*ListBucketsRequest) GetOrderBy 

func (m *ListBucketsRequest) GetOrderBy() *bucket.OrderBy

func (*ListBucketsRequest) GetPageSize 

func (m *ListBucketsRequest) GetPageSize() int32

func (*ListBucketsRequest) GetPageToken 

func (m *ListBucketsRequest) GetPageToken() *bucket.PagerCursor

func (*ListBucketsRequest) GetParent 

func (m *ListBucketsRequest) GetParent() *bucket.ParentName

func (*ListBucketsRequest) GetView 

func (m *ListBucketsRequest) GetView() view.View

func (*ListBucketsRequest) GotenMessage 

func (*ListBucketsRequest) GotenMessage()

func (*ListBucketsRequest) GotenValidate 

func (obj *ListBucketsRequest) GotenValidate() error

func (*ListBucketsRequest) Marshal 

func (m *ListBucketsRequest) Marshal() ([]byte, error)

func (*ListBucketsRequest) MarshalJSON 

func (m *ListBucketsRequest) MarshalJSON() ([]byte, error)

func (*ListBucketsRequest) ProtoMessage 

func (*ListBucketsRequest) ProtoMessage()

func (*ListBucketsRequest) ProtoReflect 

func (m *ListBucketsRequest) ProtoReflect() preflect.Message

func (*ListBucketsRequest) Reset 

func (m *ListBucketsRequest) Reset()

func (*ListBucketsRequest) SetFieldMask 

func (m *ListBucketsRequest) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*ListBucketsRequest) SetFilter 

func (m *ListBucketsRequest) SetFilter(fv *bucket.Filter)

func (*ListBucketsRequest) SetIncludePagingInfo 

func (m *ListBucketsRequest) SetIncludePagingInfo(fv bool)

func (*ListBucketsRequest) SetOrderBy 

func (m *ListBucketsRequest) SetOrderBy(fv *bucket.OrderBy)

func (*ListBucketsRequest) SetPageSize 

func (m *ListBucketsRequest) SetPageSize(fv int32)

func (*ListBucketsRequest) SetPageToken 

func (m *ListBucketsRequest) SetPageToken(fv *bucket.PagerCursor)

func (*ListBucketsRequest) SetParent 

func (m *ListBucketsRequest) SetParent(fv *bucket.ParentName)

func (*ListBucketsRequest) SetView 

func (m *ListBucketsRequest) SetView(fv view.View)

func (*ListBucketsRequest) String 

func (m *ListBucketsRequest) String() string

func (*ListBucketsRequest) Unmarshal 

func (m *ListBucketsRequest) Unmarshal(b []byte) error

func (*ListBucketsRequest) UnmarshalJSON 

func (m *ListBucketsRequest) UnmarshalJSON(data []byte) error

type ListBucketsResponse 

type ListBucketsResponse struct {

	// The list of Buckets
	Buckets []*bucket.Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty" firestore:"buckets"`
	// A token to retrieve previous page of results. Pass this value in the
	// [ListBucketsRequest.page_token][ntt.logging.v1.ListBucketsRequest.page_token]
	PrevPageToken *bucket.PagerCursor `` /* 151-byte string literal not displayed */
	// A token to retrieve next page of results. Pass this value in the
	// [ListBucketsRequest.page_token][ntt.logging.v1.ListBucketsRequest.page_token]
	NextPageToken *bucket.PagerCursor `` /* 151-byte string literal not displayed */
	// Current offset from the first page or 0 if no page tokens were given,
	// paging info was not requested or there was an error while trying to get
	// it). Page index can be computed from offset and limit provided in a
	// request.
	CurrentOffset int32 `` /* 127-byte string literal not displayed */
	// Number of total Buckets across all pages or 0, if there are no items,
	// paging info was not requested or there was an error while trying to get it.
	TotalResultsCount int32 `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [ListBuckets][ntt.logging.v1.ListBuckets]

func (*ListBucketsResponse) Descriptor 

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

Deprecated, Use ListBucketsResponse.ProtoReflect.Descriptor instead.

func (*ListBucketsResponse) GetBuckets 

func (m *ListBucketsResponse) GetBuckets() []*bucket.Bucket

func (*ListBucketsResponse) GetCurrentOffset 

func (m *ListBucketsResponse) GetCurrentOffset() int32

func (*ListBucketsResponse) GetNextPageToken 

func (m *ListBucketsResponse) GetNextPageToken() *bucket.PagerCursor

func (*ListBucketsResponse) GetPrevPageToken 

func (m *ListBucketsResponse) GetPrevPageToken() *bucket.PagerCursor

func (*ListBucketsResponse) GetTotalResultsCount 

func (m *ListBucketsResponse) GetTotalResultsCount() int32

func (*ListBucketsResponse) GotenMessage 

func (*ListBucketsResponse) GotenMessage()

func (*ListBucketsResponse) GotenValidate 

func (obj *ListBucketsResponse) GotenValidate() error

func (*ListBucketsResponse) Marshal 

func (m *ListBucketsResponse) Marshal() ([]byte, error)

func (*ListBucketsResponse) MarshalJSON 

func (m *ListBucketsResponse) MarshalJSON() ([]byte, error)

func (*ListBucketsResponse) ProtoMessage 

func (*ListBucketsResponse) ProtoMessage()

func (*ListBucketsResponse) ProtoReflect 

func (m *ListBucketsResponse) ProtoReflect() preflect.Message

func (*ListBucketsResponse) Reset 

func (m *ListBucketsResponse) Reset()

func (*ListBucketsResponse) SetBuckets 

func (m *ListBucketsResponse) SetBuckets(fv []*bucket.Bucket)

func (*ListBucketsResponse) SetCurrentOffset 

func (m *ListBucketsResponse) SetCurrentOffset(fv int32)

func (*ListBucketsResponse) SetNextPageToken 

func (m *ListBucketsResponse) SetNextPageToken(fv *bucket.PagerCursor)

func (*ListBucketsResponse) SetPrevPageToken 

func (m *ListBucketsResponse) SetPrevPageToken(fv *bucket.PagerCursor)

func (*ListBucketsResponse) SetTotalResultsCount 

func (m *ListBucketsResponse) SetTotalResultsCount(fv int32)

func (*ListBucketsResponse) String 

func (m *ListBucketsResponse) String() string

func (*ListBucketsResponse) Unmarshal 

func (m *ListBucketsResponse) Unmarshal(b []byte) error

func (*ListBucketsResponse) UnmarshalJSON 

func (m *ListBucketsResponse) UnmarshalJSON(data []byte) error

type UpdateBucketDescriptor 

type UpdateBucketDescriptor struct{}

func GetUpdateBucketDescriptor 

func GetUpdateBucketDescriptor() *UpdateBucketDescriptor

func (*UpdateBucketDescriptor) GetApiDescriptor 

func (d *UpdateBucketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*UpdateBucketDescriptor) GetApiName 

func (d *UpdateBucketDescriptor) GetApiName() string

func (*UpdateBucketDescriptor) GetClientMsgReflectHandle 

func (d *UpdateBucketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*UpdateBucketDescriptor) GetFullMethodName 

func (d *UpdateBucketDescriptor) GetFullMethodName() string

func (*UpdateBucketDescriptor) GetMethodName 

func (d *UpdateBucketDescriptor) GetMethodName() string

func (*UpdateBucketDescriptor) GetProtoPkgName 

func (d *UpdateBucketDescriptor) GetProtoPkgName() string

func (*UpdateBucketDescriptor) GetResourceDescriptor 

func (d *UpdateBucketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*UpdateBucketDescriptor) GetServerMsgReflectHandle 

func (d *UpdateBucketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*UpdateBucketDescriptor) GetServiceDomain 

func (d *UpdateBucketDescriptor) GetServiceDomain() string

func (*UpdateBucketDescriptor) GetServiceVersion 

func (d *UpdateBucketDescriptor) GetServiceVersion() string

func (*UpdateBucketDescriptor) GetVerb 

func (d *UpdateBucketDescriptor) GetVerb() string

func (*UpdateBucketDescriptor) HasResource 

func (d *UpdateBucketDescriptor) HasResource() bool

func (*UpdateBucketDescriptor) IsClientStream 

func (d *UpdateBucketDescriptor) IsClientStream() bool

func (*UpdateBucketDescriptor) IsCollection 

func (d *UpdateBucketDescriptor) IsCollection() bool

func (*UpdateBucketDescriptor) IsPlural 

func (d *UpdateBucketDescriptor) IsPlural() bool

func (*UpdateBucketDescriptor) IsServerStream 

func (d *UpdateBucketDescriptor) IsServerStream() bool

func (*UpdateBucketDescriptor) IsUnary 

func (d *UpdateBucketDescriptor) IsUnary() bool

func (*UpdateBucketDescriptor) NewEmptyClientMsg 

func (d *UpdateBucketDescriptor) NewEmptyClientMsg() proto.Message

func (*UpdateBucketDescriptor) NewEmptyServerMsg 

func (d *UpdateBucketDescriptor) NewEmptyServerMsg() proto.Message

func (*UpdateBucketDescriptor) RequestHasResourceBody 

func (d *UpdateBucketDescriptor) RequestHasResourceBody() bool

type UpdateBucketDescriptorClientMsgHandle 

type UpdateBucketDescriptorClientMsgHandle struct{}

func (*UpdateBucketDescriptorClientMsgHandle) ExtractCollectionName 

func (h *UpdateBucketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *UpdateBucketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceBody 

func (h *UpdateBucketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceName 

func (h *UpdateBucketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceNames 

func (h *UpdateBucketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type UpdateBucketDescriptorServerMsgHandle 

type UpdateBucketDescriptorServerMsgHandle struct{}

func (*UpdateBucketDescriptorServerMsgHandle) ExtractCollectionName 

func (h *UpdateBucketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *UpdateBucketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceBody 

func (h *UpdateBucketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceName 

func (h *UpdateBucketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceNames 

func (h *UpdateBucketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type UpdateBucketRequest 

type UpdateBucketRequest struct {

	// Bucket resource body
	Bucket *bucket.Bucket `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty" firestore:"bucket"`
	// FieldMask applied to request - change will be applied only for fields in
	// the mask
	UpdateMask *bucket.Bucket_FieldMask `` /* 142-byte string literal not displayed */
	// Conditional update applied to request if update should be executed only for
	// specific resource state. If this field is populated, then server will fetch
	// existing resource, compare with the one stored in the cas field (after
	// applying field mask) and proceed with update only and only if they match.
	// Otherwise RPC error Aborted will be returned.
	Cas *UpdateBucketRequest_CAS `protobuf:"bytes,4,opt,name=cas,proto3" json:"cas,omitempty" firestore:"cas"`
	// If set to true, and the resource is not found,
	// a new resource will be created.  In this situation,
	// 'field_mask' is ignored.
	//
	// https://google.aip.dev/134#create-or-update
	AllowMissing bool `protobuf:"varint,5,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty" firestore:"allowMissing"`
	// contains filtered or unexported fields
}

Request message for method [UpdateBucket][ntt.logging.v1.UpdateBucket]

func (*UpdateBucketRequest) Descriptor 

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

Deprecated, Use UpdateBucketRequest.ProtoReflect.Descriptor instead.

func (*UpdateBucketRequest) GetAllowMissing 

func (m *UpdateBucketRequest) GetAllowMissing() bool

func (*UpdateBucketRequest) GetBucket 

func (m *UpdateBucketRequest) GetBucket() *bucket.Bucket

func (*UpdateBucketRequest) GetCas 

func (m *UpdateBucketRequest) GetCas() *UpdateBucketRequest_CAS

func (*UpdateBucketRequest) GetUpdateMask 

func (m *UpdateBucketRequest) GetUpdateMask() *bucket.Bucket_FieldMask

func (*UpdateBucketRequest) GotenMessage 

func (*UpdateBucketRequest) GotenMessage()

func (*UpdateBucketRequest) GotenValidate 

func (obj *UpdateBucketRequest) GotenValidate() error

func (*UpdateBucketRequest) Marshal 

func (m *UpdateBucketRequest) Marshal() ([]byte, error)

func (*UpdateBucketRequest) MarshalJSON 

func (m *UpdateBucketRequest) MarshalJSON() ([]byte, error)

func (*UpdateBucketRequest) ProtoMessage 

func (*UpdateBucketRequest) ProtoMessage()

func (*UpdateBucketRequest) ProtoReflect 

func (m *UpdateBucketRequest) ProtoReflect() preflect.Message

func (*UpdateBucketRequest) Reset 

func (m *UpdateBucketRequest) Reset()

func (*UpdateBucketRequest) SetAllowMissing 

func (m *UpdateBucketRequest) SetAllowMissing(fv bool)

func (*UpdateBucketRequest) SetBucket 

func (m *UpdateBucketRequest) SetBucket(fv *bucket.Bucket)

func (*UpdateBucketRequest) SetCas 

func (m *UpdateBucketRequest) SetCas(fv *UpdateBucketRequest_CAS)

func (*UpdateBucketRequest) SetUpdateMask 

func (m *UpdateBucketRequest) SetUpdateMask(fv *bucket.Bucket_FieldMask)

func (*UpdateBucketRequest) String 

func (m *UpdateBucketRequest) String() string

func (*UpdateBucketRequest) Unmarshal 

func (m *UpdateBucketRequest) Unmarshal(b []byte) error

func (*UpdateBucketRequest) UnmarshalJSON 

func (m *UpdateBucketRequest) UnmarshalJSON(data []byte) error

type UpdateBucketRequest_CAS 

type UpdateBucketRequest_CAS struct {

	// Conditional desired state of a resource before update.
	ConditionalState *bucket.Bucket `` /* 138-byte string literal not displayed */
	// Field paths from conditional state of resource server should check and
	// compare.
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

CAS - Compare and Swap. This object is used if user wants to make update conditional based upon previous resource version.

func (*UpdateBucketRequest_CAS) Descriptor 

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

Deprecated, Use UpdateBucketRequest_CAS.ProtoReflect.Descriptor instead.

func (*UpdateBucketRequest_CAS) GetConditionalState 

func (m *UpdateBucketRequest_CAS) GetConditionalState() *bucket.Bucket

func (*UpdateBucketRequest_CAS) GetFieldMask 

func (m *UpdateBucketRequest_CAS) GetFieldMask() *bucket.Bucket_FieldMask

func (*UpdateBucketRequest_CAS) GotenMessage 

func (*UpdateBucketRequest_CAS) GotenMessage()

func (*UpdateBucketRequest_CAS) GotenValidate 

func (obj *UpdateBucketRequest_CAS) GotenValidate() error

func (*UpdateBucketRequest_CAS) Marshal 

func (m *UpdateBucketRequest_CAS) Marshal() ([]byte, error)

func (*UpdateBucketRequest_CAS) MarshalJSON 

func (m *UpdateBucketRequest_CAS) MarshalJSON() ([]byte, error)

func (*UpdateBucketRequest_CAS) ProtoMessage 

func (*UpdateBucketRequest_CAS) ProtoMessage()

func (*UpdateBucketRequest_CAS) ProtoReflect 

func (m *UpdateBucketRequest_CAS) ProtoReflect() preflect.Message

func (*UpdateBucketRequest_CAS) Reset 

func (m *UpdateBucketRequest_CAS) Reset()

func (*UpdateBucketRequest_CAS) SetConditionalState 

func (m *UpdateBucketRequest_CAS) SetConditionalState(fv *bucket.Bucket)

func (*UpdateBucketRequest_CAS) SetFieldMask 

func (m *UpdateBucketRequest_CAS) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*UpdateBucketRequest_CAS) String 

func (m *UpdateBucketRequest_CAS) String() string

func (*UpdateBucketRequest_CAS) Unmarshal 

func (m *UpdateBucketRequest_CAS) Unmarshal(b []byte) error

func (*UpdateBucketRequest_CAS) UnmarshalJSON 

func (m *UpdateBucketRequest_CAS) UnmarshalJSON(data []byte) error

type WatchBucketClientStream 

type WatchBucketClientStream interface {
	Recv() (*WatchBucketResponse, error)
	grpc.ClientStream
}

type WatchBucketDescriptor 

type WatchBucketDescriptor struct{}

func GetWatchBucketDescriptor 

func GetWatchBucketDescriptor() *WatchBucketDescriptor

func (*WatchBucketDescriptor) GetApiDescriptor 

func (d *WatchBucketDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*WatchBucketDescriptor) GetApiName 

func (d *WatchBucketDescriptor) GetApiName() string

func (*WatchBucketDescriptor) GetClientMsgReflectHandle 

func (d *WatchBucketDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*WatchBucketDescriptor) GetFullMethodName 

func (d *WatchBucketDescriptor) GetFullMethodName() string

func (*WatchBucketDescriptor) GetMethodName 

func (d *WatchBucketDescriptor) GetMethodName() string

func (*WatchBucketDescriptor) GetProtoPkgName 

func (d *WatchBucketDescriptor) GetProtoPkgName() string

func (*WatchBucketDescriptor) GetResourceDescriptor 

func (d *WatchBucketDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*WatchBucketDescriptor) GetServerMsgReflectHandle 

func (d *WatchBucketDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*WatchBucketDescriptor) GetServiceDomain 

func (d *WatchBucketDescriptor) GetServiceDomain() string

func (*WatchBucketDescriptor) GetServiceVersion 

func (d *WatchBucketDescriptor) GetServiceVersion() string

func (*WatchBucketDescriptor) GetVerb 

func (d *WatchBucketDescriptor) GetVerb() string

func (*WatchBucketDescriptor) HasResource 

func (d *WatchBucketDescriptor) HasResource() bool

func (*WatchBucketDescriptor) IsClientStream 

func (d *WatchBucketDescriptor) IsClientStream() bool

func (*WatchBucketDescriptor) IsCollection 

func (d *WatchBucketDescriptor) IsCollection() bool

func (*WatchBucketDescriptor) IsPlural 

func (d *WatchBucketDescriptor) IsPlural() bool

func (*WatchBucketDescriptor) IsServerStream 

func (d *WatchBucketDescriptor) IsServerStream() bool

func (*WatchBucketDescriptor) IsUnary 

func (d *WatchBucketDescriptor) IsUnary() bool

func (*WatchBucketDescriptor) NewEmptyClientMsg 

func (d *WatchBucketDescriptor) NewEmptyClientMsg() proto.Message

func (*WatchBucketDescriptor) NewEmptyServerMsg 

func (d *WatchBucketDescriptor) NewEmptyServerMsg() proto.Message

func (*WatchBucketDescriptor) RequestHasResourceBody 

func (d *WatchBucketDescriptor) RequestHasResourceBody() bool

type WatchBucketDescriptorClientMsgHandle 

type WatchBucketDescriptorClientMsgHandle struct{}

func (*WatchBucketDescriptorClientMsgHandle) ExtractCollectionName 

func (h *WatchBucketDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *WatchBucketDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceBody 

func (h *WatchBucketDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceName 

func (h *WatchBucketDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceNames 

func (h *WatchBucketDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type WatchBucketDescriptorServerMsgHandle 

type WatchBucketDescriptorServerMsgHandle struct{}

func (*WatchBucketDescriptorServerMsgHandle) ExtractCollectionName 

func (h *WatchBucketDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *WatchBucketDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceBody 

func (h *WatchBucketDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceName 

func (h *WatchBucketDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceNames 

func (h *WatchBucketDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type WatchBucketRequest 

type WatchBucketRequest struct {

	// Name of ntt.logging.v1.Bucket
	Name *bucket.Name `protobuf:"bytes,1,opt,customtype=Name,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// A list of extra fields to be obtained for each response item on top of
	// fields defined by request field view
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [WatchBucket][ntt.logging.v1.WatchBucket]

func (*WatchBucketRequest) Descriptor 

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

Deprecated, Use WatchBucketRequest.ProtoReflect.Descriptor instead.

func (*WatchBucketRequest) GetFieldMask 

func (m *WatchBucketRequest) GetFieldMask() *bucket.Bucket_FieldMask

func (*WatchBucketRequest) GetName 

func (m *WatchBucketRequest) GetName() *bucket.Name

func (*WatchBucketRequest) GetView 

func (m *WatchBucketRequest) GetView() view.View

func (*WatchBucketRequest) GotenMessage 

func (*WatchBucketRequest) GotenMessage()

func (*WatchBucketRequest) GotenValidate 

func (obj *WatchBucketRequest) GotenValidate() error

func (*WatchBucketRequest) Marshal 

func (m *WatchBucketRequest) Marshal() ([]byte, error)

func (*WatchBucketRequest) MarshalJSON 

func (m *WatchBucketRequest) MarshalJSON() ([]byte, error)

func (*WatchBucketRequest) ProtoMessage 

func (*WatchBucketRequest) ProtoMessage()

func (*WatchBucketRequest) ProtoReflect 

func (m *WatchBucketRequest) ProtoReflect() preflect.Message

func (*WatchBucketRequest) Reset 

func (m *WatchBucketRequest) Reset()

func (*WatchBucketRequest) SetFieldMask 

func (m *WatchBucketRequest) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*WatchBucketRequest) SetName 

func (m *WatchBucketRequest) SetName(fv *bucket.Name)

func (*WatchBucketRequest) SetView 

func (m *WatchBucketRequest) SetView(fv view.View)

func (*WatchBucketRequest) String 

func (m *WatchBucketRequest) String() string

func (*WatchBucketRequest) Unmarshal 

func (m *WatchBucketRequest) Unmarshal(b []byte) error

func (*WatchBucketRequest) UnmarshalJSON 

func (m *WatchBucketRequest) UnmarshalJSON(data []byte) error

type WatchBucketResponse 

type WatchBucketResponse struct {
	Change *bucket.BucketChange `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty" firestore:"change"`
	// contains filtered or unexported fields
}

WatchBucketResponse

func (*WatchBucketResponse) Descriptor 

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

Deprecated, Use WatchBucketResponse.ProtoReflect.Descriptor instead.

func (*WatchBucketResponse) GetChange 

func (m *WatchBucketResponse) GetChange() *bucket.BucketChange

func (*WatchBucketResponse) GotenMessage 

func (*WatchBucketResponse) GotenMessage()

func (*WatchBucketResponse) GotenValidate 

func (obj *WatchBucketResponse) GotenValidate() error

func (*WatchBucketResponse) Marshal 

func (m *WatchBucketResponse) Marshal() ([]byte, error)

func (*WatchBucketResponse) MarshalJSON 

func (m *WatchBucketResponse) MarshalJSON() ([]byte, error)

func (*WatchBucketResponse) ProtoMessage 

func (*WatchBucketResponse) ProtoMessage()

func (*WatchBucketResponse) ProtoReflect 

func (m *WatchBucketResponse) ProtoReflect() preflect.Message

func (*WatchBucketResponse) Reset 

func (m *WatchBucketResponse) Reset()

func (*WatchBucketResponse) SetChange 

func (m *WatchBucketResponse) SetChange(fv *bucket.BucketChange)

func (*WatchBucketResponse) String 

func (m *WatchBucketResponse) String() string

func (*WatchBucketResponse) Unmarshal 

func (m *WatchBucketResponse) Unmarshal(b []byte) error

func (*WatchBucketResponse) UnmarshalJSON 

func (m *WatchBucketResponse) UnmarshalJSON(data []byte) error

type WatchBucketsClientStream 

type WatchBucketsClientStream interface {
	Recv() (*WatchBucketsResponse, error)
	grpc.ClientStream
}

type WatchBucketsDescriptor 

type WatchBucketsDescriptor struct{}

func GetWatchBucketsDescriptor 

func GetWatchBucketsDescriptor() *WatchBucketsDescriptor

func (*WatchBucketsDescriptor) GetApiDescriptor 

func (d *WatchBucketsDescriptor) GetApiDescriptor() gotenclient.ApiDescriptor

func (*WatchBucketsDescriptor) GetApiName 

func (d *WatchBucketsDescriptor) GetApiName() string

func (*WatchBucketsDescriptor) GetClientMsgReflectHandle 

func (d *WatchBucketsDescriptor) GetClientMsgReflectHandle() gotenclient.MethodMsgHandle

func (*WatchBucketsDescriptor) GetFullMethodName 

func (d *WatchBucketsDescriptor) GetFullMethodName() string

func (*WatchBucketsDescriptor) GetMethodName 

func (d *WatchBucketsDescriptor) GetMethodName() string

func (*WatchBucketsDescriptor) GetProtoPkgName 

func (d *WatchBucketsDescriptor) GetProtoPkgName() string

func (*WatchBucketsDescriptor) GetResourceDescriptor 

func (d *WatchBucketsDescriptor) GetResourceDescriptor() gotenresource.Descriptor

func (*WatchBucketsDescriptor) GetServerMsgReflectHandle 

func (d *WatchBucketsDescriptor) GetServerMsgReflectHandle() gotenclient.MethodMsgHandle

func (*WatchBucketsDescriptor) GetServiceDomain 

func (d *WatchBucketsDescriptor) GetServiceDomain() string

func (*WatchBucketsDescriptor) GetServiceVersion 

func (d *WatchBucketsDescriptor) GetServiceVersion() string

func (*WatchBucketsDescriptor) GetVerb 

func (d *WatchBucketsDescriptor) GetVerb() string

func (*WatchBucketsDescriptor) HasResource 

func (d *WatchBucketsDescriptor) HasResource() bool

func (*WatchBucketsDescriptor) IsClientStream 

func (d *WatchBucketsDescriptor) IsClientStream() bool

func (*WatchBucketsDescriptor) IsCollection 

func (d *WatchBucketsDescriptor) IsCollection() bool

func (*WatchBucketsDescriptor) IsPlural 

func (d *WatchBucketsDescriptor) IsPlural() bool

func (*WatchBucketsDescriptor) IsServerStream 

func (d *WatchBucketsDescriptor) IsServerStream() bool

func (*WatchBucketsDescriptor) IsUnary 

func (d *WatchBucketsDescriptor) IsUnary() bool

func (*WatchBucketsDescriptor) NewEmptyClientMsg 

func (d *WatchBucketsDescriptor) NewEmptyClientMsg() proto.Message

func (*WatchBucketsDescriptor) NewEmptyServerMsg 

func (d *WatchBucketsDescriptor) NewEmptyServerMsg() proto.Message

func (*WatchBucketsDescriptor) RequestHasResourceBody 

func (d *WatchBucketsDescriptor) RequestHasResourceBody() bool

type WatchBucketsDescriptorClientMsgHandle 

type WatchBucketsDescriptorClientMsgHandle struct{}

func (*WatchBucketsDescriptorClientMsgHandle) ExtractCollectionName 

func (h *WatchBucketsDescriptorClientMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceBodies 

func (h *WatchBucketsDescriptorClientMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceBody 

func (h *WatchBucketsDescriptorClientMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceName 

func (h *WatchBucketsDescriptorClientMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceNames 

func (h *WatchBucketsDescriptorClientMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type WatchBucketsDescriptorServerMsgHandle 

type WatchBucketsDescriptorServerMsgHandle struct{}

func (*WatchBucketsDescriptorServerMsgHandle) ExtractCollectionName 

func (h *WatchBucketsDescriptorServerMsgHandle) ExtractCollectionName(msg proto.Message) gotenresource.Name

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceBodies 

func (h *WatchBucketsDescriptorServerMsgHandle) ExtractResourceBodies(msg proto.Message) gotenresource.ResourceList

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceBody 

func (h *WatchBucketsDescriptorServerMsgHandle) ExtractResourceBody(msg proto.Message) gotenresource.Resource

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceName 

func (h *WatchBucketsDescriptorServerMsgHandle) ExtractResourceName(msg proto.Message) gotenresource.Name

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceNames 

func (h *WatchBucketsDescriptorServerMsgHandle) ExtractResourceNames(msg proto.Message) gotenresource.NameList

type WatchBucketsRequest 

type WatchBucketsRequest struct {

	// Type of a watch. Identifies how server stream data to a client, which
	// fields in a request are allowed and which fields in response are relevant.
	Type watch_type.WatchType `protobuf:"varint,9,opt,name=type,proto3,enum=goten.types.WatchType" json:"type,omitempty" firestore:"type"`
	// Parent name of ntt.logging.v1.Bucket
	Parent *bucket.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Buckets than requested.
	// If unspecified, server will pick an appropriate default.
	// Can be populated only for stateful watch type.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty" firestore:"pageSize"`
	// A token identifying a page of results the server should return.
	// Can be populated only for stateful watch type.
	PageToken *bucket.PagerCursor `` /* 133-byte string literal not displayed */
	// Order By -
	// https://cloud.google.com/apis/design/design_patterns#list_pagination Can be
	// populated only for stateful watch type.
	OrderBy *bucket.OrderBy `protobuf:"bytes,4,opt,customtype=OrderBy,name=order_by,json=orderBy,proto3" json:"order_by,omitempty" firestore:"orderBy"`
	// A token identifying watch resume point from previous session.
	// Can be populated only for stateless watch type.
	ResumeToken string `protobuf:"bytes,10,opt,name=resume_token,json=resumeToken,proto3" json:"resume_token,omitempty" firestore:"resumeToken"`
	// Point in the time from which we want to start getting updates. This field
	// can be populated only for stateless watch type and if resume token is not
	// known yet. If specified, initial snapshot will NOT be provided. It is
	// assumed client can obtain it using separate means. Watch responses will
	// contain resume tokens which should be used to resume broken connection.
	StartingTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=starting_time,json=startingTime,proto3" json:"starting_time,omitempty" firestore:"startingTime"`
	// Filter - filter results by field criteria. Simplified SQL-like syntax with
	// following operators:
	// <=, >=, =, !=, <, >, LIKE, CONTAINS (aliases CONTAIN, HAS, HAVE), IN, IS
	// [NOT] NULL | NaN . Combine conditions with OR | AND example: 'meta.labels
	// CONTAINS "severity:important" OR (state.last_error_time >
	// "2018-11-15T10:00:00Z" AND state.status = "ERROR")'
	Filter *bucket.Filter `protobuf:"bytes,5,opt,customtype=Filter,name=filter,proto3" json:"filter,omitempty" firestore:"filter"`
	// A list of extra fields to be obtained for each response item on top of
	// fields defined by request field view Changes to Bucket that don't affect
	// any of masked fields won't be sent back.
	FieldMask *bucket.Bucket_FieldMask `` /* 138-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask Changes to
	// Bucket that don't affect any of masked fields won't be sent back.
	View view.View `protobuf:"varint,8,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// Maximum amount of changes in each response message. Query result response
	// is divided on the server side into chunks with size of a specified amount
	// to limit memory footprint of each message. Responses will hold information
	// whether more elements will continue for the actual change. If unspecified,
	// server will pick an appropriate default.
	MaxChunkSize int32 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [WatchBuckets][ntt.logging.v1.WatchBuckets]

func (*WatchBucketsRequest) Descriptor 

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

Deprecated, Use WatchBucketsRequest.ProtoReflect.Descriptor instead.

func (*WatchBucketsRequest) GetFieldMask 

func (m *WatchBucketsRequest) GetFieldMask() *bucket.Bucket_FieldMask

func (*WatchBucketsRequest) GetFilter 

func (m *WatchBucketsRequest) GetFilter() *bucket.Filter

func (*WatchBucketsRequest) GetMaxChunkSize 

func (m *WatchBucketsRequest) GetMaxChunkSize() int32

func (*WatchBucketsRequest) GetOrderBy 

func (m *WatchBucketsRequest) GetOrderBy() *bucket.OrderBy

func (*WatchBucketsRequest) GetPageSize 

func (m *WatchBucketsRequest) GetPageSize() int32

func (*WatchBucketsRequest) GetPageToken 

func (m *WatchBucketsRequest) GetPageToken() *bucket.PagerCursor

func (*WatchBucketsRequest) GetParent 

func (m *WatchBucketsRequest) GetParent() *bucket.ParentName

func (*WatchBucketsRequest) GetResumeToken 

func (m *WatchBucketsRequest) GetResumeToken() string

func (*WatchBucketsRequest) GetStartingTime 

func (m *WatchBucketsRequest) GetStartingTime() *timestamppb.Timestamp

func (*WatchBucketsRequest) GetType 

func (m *WatchBucketsRequest) GetType() watch_type.WatchType

func (*WatchBucketsRequest) GetView 

func (m *WatchBucketsRequest) GetView() view.View

func (*WatchBucketsRequest) GotenMessage 

func (*WatchBucketsRequest) GotenMessage()

func (*WatchBucketsRequest) GotenValidate 

func (obj *WatchBucketsRequest) GotenValidate() error

func (*WatchBucketsRequest) Marshal 

func (m *WatchBucketsRequest) Marshal() ([]byte, error)

func (*WatchBucketsRequest) MarshalJSON 

func (m *WatchBucketsRequest) MarshalJSON() ([]byte, error)

func (*WatchBucketsRequest) ProtoMessage 

func (*WatchBucketsRequest) ProtoMessage()

func (*WatchBucketsRequest) ProtoReflect 

func (m *WatchBucketsRequest) ProtoReflect() preflect.Message

func (*WatchBucketsRequest) Reset 

func (m *WatchBucketsRequest) Reset()

func (*WatchBucketsRequest) SetFieldMask 

func (m *WatchBucketsRequest) SetFieldMask(fv *bucket.Bucket_FieldMask)

func (*WatchBucketsRequest) SetFilter 

func (m *WatchBucketsRequest) SetFilter(fv *bucket.Filter)

func (*WatchBucketsRequest) SetMaxChunkSize 

func (m *WatchBucketsRequest) SetMaxChunkSize(fv int32)

func (*WatchBucketsRequest) SetOrderBy 

func (m *WatchBucketsRequest) SetOrderBy(fv *bucket.OrderBy)

func (*WatchBucketsRequest) SetPageSize 

func (m *WatchBucketsRequest) SetPageSize(fv int32)

func (*WatchBucketsRequest) SetPageToken 

func (m *WatchBucketsRequest) SetPageToken(fv *bucket.PagerCursor)

func (*WatchBucketsRequest) SetParent 

func (m *WatchBucketsRequest) SetParent(fv *bucket.ParentName)

func (*WatchBucketsRequest) SetResumeToken 

func (m *WatchBucketsRequest) SetResumeToken(fv string)

func (*WatchBucketsRequest) SetStartingTime 

func (m *WatchBucketsRequest) SetStartingTime(fv *timestamppb.Timestamp)

func (*WatchBucketsRequest) SetType 

func (m *WatchBucketsRequest) SetType(fv watch_type.WatchType)

func (*WatchBucketsRequest) SetView 

func (m *WatchBucketsRequest) SetView(fv view.View)

func (*WatchBucketsRequest) String 

func (m *WatchBucketsRequest) String() string

func (*WatchBucketsRequest) Unmarshal 

func (m *WatchBucketsRequest) Unmarshal(b []byte) error

func (*WatchBucketsRequest) UnmarshalJSON 

func (m *WatchBucketsRequest) UnmarshalJSON(data []byte) error

type WatchBucketsResponse 

type WatchBucketsResponse struct {

	// Changes of Buckets
	BucketChanges []*bucket.BucketChange `` /* 126-byte string literal not displayed */
	// If request specified max_chunk_size (or this limit was enforced if
	// stateless watch has been chosen), then responses with "full changeset" will
	// be divided into chunks. Client should keep receiving messages and, once
	// is_current has value true, combine this recent message with all previous
	// ones where is_current is false. If this is the first is_current in a whole
	// watch stream, then it means that client should have, at this moment,
	// contain snapshot of the current situation (or more accurately, snapshot of
	// situation at the moment of request). All Buckets will be of type
	// Added/Current (depending on watch_type specified in the request). Further
	// responses will be incremental - however messages may still be chunked and
	// is_current logic still applies. is_current is always true for stateful
	// watch if max_chunk_size was left to 0.
	IsCurrent bool `protobuf:"varint,4,opt,name=is_current,json=isCurrent,proto3" json:"is_current,omitempty" firestore:"isCurrent"`
	// When present, PageTokens used for page navigation should be updated.
	// Present only if is_current is true (last chunk).
	PageTokenChange *WatchBucketsResponse_PageTokenChange `` /* 136-byte string literal not displayed */
	// Token that can be used if current connection drops and client needs to
	// reconnect. Populated only for stateless watch type. Present only if
	// is_current is true (last chunk).
	ResumeToken string `protobuf:"bytes,5,opt,name=resume_token,json=resumeToken,proto3" json:"resume_token,omitempty" firestore:"resumeToken"`
	// Server may occasionally send information how many resources should client
	// have in its state so far (response message without any changes, but with
	// snapshot_size field specified). If client has different value than the one
	// sent by the server, then it should be treated by a client as an error and
	// should reconnect. If value is smaller then 0, then client should ignore
	// this field as unpopulated. This field should be checked only for stateless
	// watch. In stateful those kind of errors are handled by the server side.
	// Will be never sent together with is_current, is_soft_reset and
	// is_hard_reset flags.
	SnapshotSize int64 `protobuf:"varint,6,opt,name=snapshot_size,json=snapshotSize,proto3" json:"snapshot_size,omitempty" firestore:"snapshotSize"`
	// In case of internal issue server may send response message with this flag.
	// It indicates that client should drop all changes from recent responses
	// where is_current is false only! If last message had is_current set to true,
	// client should do nothing and process normally. Resume token received before
	// is still valid. This field should be checked only for stateless watch. In
	// stateful those kind of errors are handled by the server side. Will never be
	// sent along with is_current, is_hard_reset or snapshot_size.
	IsSoftReset bool `protobuf:"varint,7,opt,name=is_soft_reset,json=isSoftReset,proto3" json:"is_soft_reset,omitempty" firestore:"isSoftReset"`
	// In case of internal issue server may send response message with this flag.
	// After receiving, client should clear whole state (drop all changes received
	// so far) as server will send new snapshot (Buckets will contains changes of
	// type Current only). Any resume tokens should be discarded as well. This
	// field should be checked only for stateless watch. In stateful those kind of
	// errors are handled by the server side. Will never be sent along with
	// is_current, is_soft_reset or snapshot_size.
	IsHardReset bool `protobuf:"varint,8,opt,name=is_hard_reset,json=isHardReset,proto3" json:"is_hard_reset,omitempty" firestore:"isHardReset"`
	// contains filtered or unexported fields
}

WatchBucketsResponse

func (*WatchBucketsResponse) Descriptor 

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

Deprecated, Use WatchBucketsResponse.ProtoReflect.Descriptor instead.

func (*WatchBucketsResponse) GetBucketChanges 

func (m *WatchBucketsResponse) GetBucketChanges() []*bucket.BucketChange

func (*WatchBucketsResponse) GetIsCurrent 

func (m *WatchBucketsResponse) GetIsCurrent() bool

func (*WatchBucketsResponse) GetIsHardReset 

func (m *WatchBucketsResponse) GetIsHardReset() bool

func (*WatchBucketsResponse) GetIsSoftReset 

func (m *WatchBucketsResponse) GetIsSoftReset() bool

func (*WatchBucketsResponse) GetPageTokenChange 

func (m *WatchBucketsResponse) GetPageTokenChange() *WatchBucketsResponse_PageTokenChange

func (*WatchBucketsResponse) GetResumeToken 

func (m *WatchBucketsResponse) GetResumeToken() string

func (*WatchBucketsResponse) GetSnapshotSize 

func (m *WatchBucketsResponse) GetSnapshotSize() int64

func (*WatchBucketsResponse) GotenMessage 

func (*WatchBucketsResponse) GotenMessage()

func (*WatchBucketsResponse) GotenValidate 

func (obj *WatchBucketsResponse) GotenValidate() error

func (*WatchBucketsResponse) Marshal 

func (m *WatchBucketsResponse) Marshal() ([]byte, error)

func (*WatchBucketsResponse) MarshalJSON 

func (m *WatchBucketsResponse) MarshalJSON() ([]byte, error)

func (*WatchBucketsResponse) ProtoMessage 

func (*WatchBucketsResponse) ProtoMessage()

func (*WatchBucketsResponse) ProtoReflect 

func (m *WatchBucketsResponse) ProtoReflect() preflect.Message

func (*WatchBucketsResponse) Reset 

func (m *WatchBucketsResponse) Reset()

func (*WatchBucketsResponse) SetBucketChanges 

func (m *WatchBucketsResponse) SetBucketChanges(fv []*bucket.BucketChange)

func (*WatchBucketsResponse) SetIsCurrent 

func (m *WatchBucketsResponse) SetIsCurrent(fv bool)

func (*WatchBucketsResponse) SetIsHardReset 

func (m *WatchBucketsResponse) SetIsHardReset(fv bool)

func (*WatchBucketsResponse) SetIsSoftReset 

func (m *WatchBucketsResponse) SetIsSoftReset(fv bool)

func (*WatchBucketsResponse) SetPageTokenChange 

func (m *WatchBucketsResponse) SetPageTokenChange(fv *WatchBucketsResponse_PageTokenChange)

func (*WatchBucketsResponse) SetResumeToken 

func (m *WatchBucketsResponse) SetResumeToken(fv string)

func (*WatchBucketsResponse) SetSnapshotSize 

func (m *WatchBucketsResponse) SetSnapshotSize(fv int64)

func (*WatchBucketsResponse) String 

func (m *WatchBucketsResponse) String() string

func (*WatchBucketsResponse) Unmarshal 

func (m *WatchBucketsResponse) Unmarshal(b []byte) error

func (*WatchBucketsResponse) UnmarshalJSON 

func (m *WatchBucketsResponse) UnmarshalJSON(data []byte) error

type WatchBucketsResponse_PageTokenChange 

type WatchBucketsResponse_PageTokenChange struct {

	// New token to retrieve previous page of results.
	PrevPageToken *bucket.PagerCursor `` /* 151-byte string literal not displayed */
	// New token to retrieve next page of results.
	NextPageToken *bucket.PagerCursor `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WatchBucketsResponse_PageTokenChange) Descriptor 

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

Deprecated, Use WatchBucketsResponse_PageTokenChange.ProtoReflect.Descriptor instead.

func (*WatchBucketsResponse_PageTokenChange) GetNextPageToken 

func (m *WatchBucketsResponse_PageTokenChange) GetNextPageToken() *bucket.PagerCursor

func (*WatchBucketsResponse_PageTokenChange) GetPrevPageToken 

func (m *WatchBucketsResponse_PageTokenChange) GetPrevPageToken() *bucket.PagerCursor

func (*WatchBucketsResponse_PageTokenChange) GotenMessage 

func (*WatchBucketsResponse_PageTokenChange) GotenMessage()

func (*WatchBucketsResponse_PageTokenChange) GotenValidate 

func (obj *WatchBucketsResponse_PageTokenChange) GotenValidate() error

func (*WatchBucketsResponse_PageTokenChange) Marshal 

func (m *WatchBucketsResponse_PageTokenChange) Marshal() ([]byte, error)

func (*WatchBucketsResponse_PageTokenChange) MarshalJSON 

func (m *WatchBucketsResponse_PageTokenChange) MarshalJSON() ([]byte, error)

func (*WatchBucketsResponse_PageTokenChange) ProtoMessage 

func (*WatchBucketsResponse_PageTokenChange) ProtoMessage()

func (*WatchBucketsResponse_PageTokenChange) ProtoReflect 

func (m *WatchBucketsResponse_PageTokenChange) ProtoReflect() preflect.Message

func (*WatchBucketsResponse_PageTokenChange) Reset 

func (m *WatchBucketsResponse_PageTokenChange) Reset()

func (*WatchBucketsResponse_PageTokenChange) SetNextPageToken 

func (m *WatchBucketsResponse_PageTokenChange) SetNextPageToken(fv *bucket.PagerCursor)

func (*WatchBucketsResponse_PageTokenChange) SetPrevPageToken 

func (m *WatchBucketsResponse_PageTokenChange) SetPrevPageToken(fv *bucket.PagerCursor)

func (*WatchBucketsResponse_PageTokenChange) String 

func (m *WatchBucketsResponse_PageTokenChange) String() string

func (*WatchBucketsResponse_PageTokenChange) Unmarshal 

func (m *WatchBucketsResponse_PageTokenChange) Unmarshal(b []byte) error

func (*WatchBucketsResponse_PageTokenChange) UnmarshalJSON 

func (m *WatchBucketsResponse_PageTokenChange) UnmarshalJSON(data []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.