bucket_client

package
v1.0.31 Latest Latest
Warning

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

Go to latest
Published: Apr 23, 2024 License: Apache-2.0 Imports: 27 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 (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBodies

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceBody

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceName

func (*BatchGetBucketsDescriptorClientMsgHandle) ExtractResourceNames

type BatchGetBucketsDescriptorServerMsgHandle

type BatchGetBucketsDescriptorServerMsgHandle struct{}

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractCollectionName

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBodies

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceBody

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceName

func (*BatchGetBucketsDescriptorServerMsgHandle) ExtractResourceNames

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.monitoring.v4.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.

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 (*CreateBucketDescriptorClientMsgHandle) ExtractResourceBodies

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceBody

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceName

func (*CreateBucketDescriptorClientMsgHandle) ExtractResourceNames

type CreateBucketDescriptorServerMsgHandle

type CreateBucketDescriptorServerMsgHandle struct{}

func (*CreateBucketDescriptorServerMsgHandle) ExtractCollectionName

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceBodies

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceBody

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceName

func (*CreateBucketDescriptorServerMsgHandle) ExtractResourceNames

type CreateBucketRequest

type CreateBucketRequest struct {

	// Parent name of ntt.monitoring.v4.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.monitoring.v4.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 (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceBodies

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceBody

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceName

func (*DeleteBucketDescriptorClientMsgHandle) ExtractResourceNames

type DeleteBucketDescriptorServerMsgHandle

type DeleteBucketDescriptorServerMsgHandle struct{}

func (*DeleteBucketDescriptorServerMsgHandle) ExtractCollectionName

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceBodies

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceBody

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceName

func (*DeleteBucketDescriptorServerMsgHandle) ExtractResourceNames

type DeleteBucketRequest

type DeleteBucketRequest struct {

	// Name of ntt.monitoring.v4.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.monitoring.v4.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 (*GetBucketDescriptorClientMsgHandle) ExtractResourceBody

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceName

func (*GetBucketDescriptorClientMsgHandle) ExtractResourceNames

type GetBucketDescriptorServerMsgHandle

type GetBucketDescriptorServerMsgHandle struct{}

func (*GetBucketDescriptorServerMsgHandle) ExtractCollectionName

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

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceBodies

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceBody

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceName

func (*GetBucketDescriptorServerMsgHandle) ExtractResourceNames

type GetBucketRequest

type GetBucketRequest struct {

	// Name of ntt.monitoring.v4.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.monitoring.v4.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 (*ListBucketsDescriptorClientMsgHandle) ExtractResourceBodies

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceBody

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceName

func (*ListBucketsDescriptorClientMsgHandle) ExtractResourceNames

type ListBucketsDescriptorServerMsgHandle

type ListBucketsDescriptorServerMsgHandle struct{}

func (*ListBucketsDescriptorServerMsgHandle) ExtractCollectionName

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceBodies

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceBody

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceName

func (*ListBucketsDescriptorServerMsgHandle) ExtractResourceNames

type ListBucketsRequest

type ListBucketsRequest struct {

	// Parent name of ntt.monitoring.v4.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.monitoring.v4.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.monitoring.v4.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.monitoring.v4.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.monitoring.v4.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.monitoring.v4.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 (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceBodies

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceBody

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceName

func (*UpdateBucketDescriptorClientMsgHandle) ExtractResourceNames

type UpdateBucketDescriptorServerMsgHandle

type UpdateBucketDescriptorServerMsgHandle struct{}

func (*UpdateBucketDescriptorServerMsgHandle) ExtractCollectionName

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceBodies

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceBody

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceName

func (*UpdateBucketDescriptorServerMsgHandle) ExtractResourceNames

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.monitoring.v4.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 (*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 (*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 (*WatchBucketDescriptorClientMsgHandle) ExtractResourceBodies

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceBody

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceName

func (*WatchBucketDescriptorClientMsgHandle) ExtractResourceNames

type WatchBucketDescriptorServerMsgHandle

type WatchBucketDescriptorServerMsgHandle struct{}

func (*WatchBucketDescriptorServerMsgHandle) ExtractCollectionName

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceBodies

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceBody

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceName

func (*WatchBucketDescriptorServerMsgHandle) ExtractResourceNames

type WatchBucketRequest

type WatchBucketRequest struct {

	// Name of ntt.monitoring.v4.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.monitoring.v4.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 (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceBodies

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceBody

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceName

func (*WatchBucketsDescriptorClientMsgHandle) ExtractResourceNames

type WatchBucketsDescriptorServerMsgHandle

type WatchBucketsDescriptorServerMsgHandle struct{}

func (*WatchBucketsDescriptorServerMsgHandle) ExtractCollectionName

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceBodies

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceBody

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceName

func (*WatchBucketsDescriptorServerMsgHandle) ExtractResourceNames

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.monitoring.v4.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.monitoring.v4.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 (*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 (*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 (*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 (*WatchBucketsResponse_PageTokenChange) GetPrevPageToken

func (*WatchBucketsResponse_PageTokenChange) GotenMessage

func (*WatchBucketsResponse_PageTokenChange) GotenMessage()

func (*WatchBucketsResponse_PageTokenChange) GotenValidate

func (obj *WatchBucketsResponse_PageTokenChange) GotenValidate() error

func (*WatchBucketsResponse_PageTokenChange) Marshal

func (*WatchBucketsResponse_PageTokenChange) MarshalJSON

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

func (*WatchBucketsResponse_PageTokenChange) ProtoMessage

func (*WatchBucketsResponse_PageTokenChange) ProtoMessage()

func (*WatchBucketsResponse_PageTokenChange) ProtoReflect

func (*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 (*WatchBucketsResponse_PageTokenChange) Unmarshal

func (*WatchBucketsResponse_PageTokenChange) UnmarshalJSON

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL