distribution_client

package
v1.5.9 Latest Latest
Warning

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

Go to latest
Published: Oct 3, 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 BatchGetDistributionsDescriptor added in v0.4.28

type BatchGetDistributionsDescriptor struct{}

func GetBatchGetDistributionsDescriptor added in v0.4.28

func GetBatchGetDistributionsDescriptor() *BatchGetDistributionsDescriptor

func (*BatchGetDistributionsDescriptor) GetApiDescriptor added in v0.4.28

func (*BatchGetDistributionsDescriptor) GetApiName added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetApiName() string

func (*BatchGetDistributionsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*BatchGetDistributionsDescriptor) GetFullMethodName added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetFullMethodName() string

func (*BatchGetDistributionsDescriptor) GetMethodName added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetMethodName() string

func (*BatchGetDistributionsDescriptor) GetProtoPkgName added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetProtoPkgName() string

func (*BatchGetDistributionsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*BatchGetDistributionsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*BatchGetDistributionsDescriptor) GetServiceDomain added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetServiceDomain() string

func (*BatchGetDistributionsDescriptor) GetServiceVersion added in v0.4.28

func (d *BatchGetDistributionsDescriptor) GetServiceVersion() string

func (*BatchGetDistributionsDescriptor) GetVerb added in v0.4.28

func (*BatchGetDistributionsDescriptor) HasResource added in v0.4.30

func (d *BatchGetDistributionsDescriptor) HasResource() bool

func (*BatchGetDistributionsDescriptor) IsClientStream added in v0.4.28

func (d *BatchGetDistributionsDescriptor) IsClientStream() bool

func (*BatchGetDistributionsDescriptor) IsCollection added in v0.4.30

func (d *BatchGetDistributionsDescriptor) IsCollection() bool

func (*BatchGetDistributionsDescriptor) IsPlural added in v0.4.30

func (d *BatchGetDistributionsDescriptor) IsPlural() bool

func (*BatchGetDistributionsDescriptor) IsServerStream added in v0.4.28

func (d *BatchGetDistributionsDescriptor) IsServerStream() bool

func (*BatchGetDistributionsDescriptor) IsUnary added in v0.4.28

func (*BatchGetDistributionsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*BatchGetDistributionsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*BatchGetDistributionsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *BatchGetDistributionsDescriptor) RequestHasResourceBody() bool

type BatchGetDistributionsDescriptorClientMsgHandle added in v0.4.28

type BatchGetDistributionsDescriptorClientMsgHandle struct{}

func (*BatchGetDistributionsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetDistributionsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetDistributionsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetDistributionsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetDistributionsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetDistributionsDescriptorServerMsgHandle added in v0.4.28

type BatchGetDistributionsDescriptorServerMsgHandle struct{}

func (*BatchGetDistributionsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetDistributionsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetDistributionsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetDistributionsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetDistributionsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetDistributionsRequest

type BatchGetDistributionsRequest struct {

	// Names of Distributions
	Names []*distribution.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 *distribution.Distribution_FieldMask `` /* 144-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
}

A request message of the BatchGetDistributions method.

func (*BatchGetDistributionsRequest) Descriptor

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

Deprecated, Use BatchGetDistributionsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetDistributionsRequest) GetFieldMask

func (*BatchGetDistributionsRequest) GetNames

func (*BatchGetDistributionsRequest) GetView

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

func (*BatchGetDistributionsRequest) GotenMessage

func (*BatchGetDistributionsRequest) GotenMessage()

func (*BatchGetDistributionsRequest) GotenValidate

func (obj *BatchGetDistributionsRequest) GotenValidate() error

func (*BatchGetDistributionsRequest) Marshal

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

func (*BatchGetDistributionsRequest) MarshalJSON

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

func (*BatchGetDistributionsRequest) ProtoMessage

func (*BatchGetDistributionsRequest) ProtoMessage()

func (*BatchGetDistributionsRequest) ProtoReflect

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

func (*BatchGetDistributionsRequest) Reset

func (m *BatchGetDistributionsRequest) Reset()

func (*BatchGetDistributionsRequest) SetFieldMask

func (*BatchGetDistributionsRequest) SetNames

func (m *BatchGetDistributionsRequest) SetNames(fv []*distribution.Name)

func (*BatchGetDistributionsRequest) SetView

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

func (*BatchGetDistributionsRequest) String

func (*BatchGetDistributionsRequest) Unmarshal

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

func (*BatchGetDistributionsRequest) UnmarshalJSON

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

type BatchGetDistributionsResponse

type BatchGetDistributionsResponse struct {

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

A response message of the BatchGetDistributions method.

func (*BatchGetDistributionsResponse) Descriptor

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

Deprecated, Use BatchGetDistributionsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetDistributionsResponse) GetDistributions

func (m *BatchGetDistributionsResponse) GetDistributions() []*distribution.Distribution

func (*BatchGetDistributionsResponse) GetMissing

func (m *BatchGetDistributionsResponse) GetMissing() []*distribution.Name

func (*BatchGetDistributionsResponse) GotenMessage

func (*BatchGetDistributionsResponse) GotenMessage()

func (*BatchGetDistributionsResponse) GotenValidate

func (obj *BatchGetDistributionsResponse) GotenValidate() error

func (*BatchGetDistributionsResponse) Marshal

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

func (*BatchGetDistributionsResponse) MarshalJSON

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

func (*BatchGetDistributionsResponse) ProtoMessage

func (*BatchGetDistributionsResponse) ProtoMessage()

func (*BatchGetDistributionsResponse) ProtoReflect

func (*BatchGetDistributionsResponse) Reset

func (m *BatchGetDistributionsResponse) Reset()

func (*BatchGetDistributionsResponse) SetDistributions

func (m *BatchGetDistributionsResponse) SetDistributions(fv []*distribution.Distribution)

func (*BatchGetDistributionsResponse) SetMissing

func (m *BatchGetDistributionsResponse) SetMissing(fv []*distribution.Name)

func (*BatchGetDistributionsResponse) String

func (*BatchGetDistributionsResponse) Unmarshal

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

func (*BatchGetDistributionsResponse) UnmarshalJSON

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

type CreateDistributionDescriptor added in v0.4.28

type CreateDistributionDescriptor struct{}

func GetCreateDistributionDescriptor added in v0.4.28

func GetCreateDistributionDescriptor() *CreateDistributionDescriptor

func (*CreateDistributionDescriptor) GetApiDescriptor added in v0.4.28

func (*CreateDistributionDescriptor) GetApiName added in v0.4.28

func (d *CreateDistributionDescriptor) GetApiName() string

func (*CreateDistributionDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*CreateDistributionDescriptor) GetFullMethodName added in v0.4.28

func (d *CreateDistributionDescriptor) GetFullMethodName() string

func (*CreateDistributionDescriptor) GetMethodName added in v0.4.28

func (d *CreateDistributionDescriptor) GetMethodName() string

func (*CreateDistributionDescriptor) GetProtoPkgName added in v0.4.28

func (d *CreateDistributionDescriptor) GetProtoPkgName() string

func (*CreateDistributionDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*CreateDistributionDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*CreateDistributionDescriptor) GetServiceDomain added in v0.4.28

func (d *CreateDistributionDescriptor) GetServiceDomain() string

func (*CreateDistributionDescriptor) GetServiceVersion added in v0.4.28

func (d *CreateDistributionDescriptor) GetServiceVersion() string

func (*CreateDistributionDescriptor) GetVerb added in v0.4.28

func (d *CreateDistributionDescriptor) GetVerb() string

func (*CreateDistributionDescriptor) HasResource added in v0.4.30

func (d *CreateDistributionDescriptor) HasResource() bool

func (*CreateDistributionDescriptor) IsClientStream added in v0.4.28

func (d *CreateDistributionDescriptor) IsClientStream() bool

func (*CreateDistributionDescriptor) IsCollection added in v0.4.30

func (d *CreateDistributionDescriptor) IsCollection() bool

func (*CreateDistributionDescriptor) IsPlural added in v0.4.30

func (d *CreateDistributionDescriptor) IsPlural() bool

func (*CreateDistributionDescriptor) IsServerStream added in v0.4.28

func (d *CreateDistributionDescriptor) IsServerStream() bool

func (*CreateDistributionDescriptor) IsUnary added in v0.4.28

func (d *CreateDistributionDescriptor) IsUnary() bool

func (*CreateDistributionDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*CreateDistributionDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*CreateDistributionDescriptor) RequestHasResourceBody added in v0.4.28

func (d *CreateDistributionDescriptor) RequestHasResourceBody() bool

type CreateDistributionDescriptorClientMsgHandle added in v0.4.28

type CreateDistributionDescriptorClientMsgHandle struct{}

func (*CreateDistributionDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*CreateDistributionDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*CreateDistributionDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*CreateDistributionDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*CreateDistributionDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type CreateDistributionDescriptorServerMsgHandle added in v0.4.28

type CreateDistributionDescriptorServerMsgHandle struct{}

func (*CreateDistributionDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*CreateDistributionDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*CreateDistributionDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*CreateDistributionDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*CreateDistributionDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type CreateDistributionRequest

type CreateDistributionRequest struct {

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

A request message of the CreateDistribution method.

func (*CreateDistributionRequest) Descriptor

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

Deprecated, Use CreateDistributionRequest.ProtoReflect.Descriptor instead.

func (*CreateDistributionRequest) GetDistribution

func (m *CreateDistributionRequest) GetDistribution() *distribution.Distribution

func (*CreateDistributionRequest) GetParent

func (*CreateDistributionRequest) GotenMessage

func (*CreateDistributionRequest) GotenMessage()

func (*CreateDistributionRequest) GotenValidate

func (obj *CreateDistributionRequest) GotenValidate() error

func (*CreateDistributionRequest) Marshal

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

func (*CreateDistributionRequest) MarshalJSON

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

func (*CreateDistributionRequest) ProtoMessage

func (*CreateDistributionRequest) ProtoMessage()

func (*CreateDistributionRequest) ProtoReflect

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

func (*CreateDistributionRequest) Reset

func (m *CreateDistributionRequest) Reset()

func (*CreateDistributionRequest) SetDistribution

func (m *CreateDistributionRequest) SetDistribution(fv *distribution.Distribution)

func (*CreateDistributionRequest) SetParent

func (*CreateDistributionRequest) String

func (m *CreateDistributionRequest) String() string

func (*CreateDistributionRequest) Unmarshal

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

func (*CreateDistributionRequest) UnmarshalJSON

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

type DeleteDistributionDescriptor added in v0.4.28

type DeleteDistributionDescriptor struct{}

func GetDeleteDistributionDescriptor added in v0.4.28

func GetDeleteDistributionDescriptor() *DeleteDistributionDescriptor

func (*DeleteDistributionDescriptor) GetApiDescriptor added in v0.4.28

func (*DeleteDistributionDescriptor) GetApiName added in v0.4.28

func (d *DeleteDistributionDescriptor) GetApiName() string

func (*DeleteDistributionDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*DeleteDistributionDescriptor) GetFullMethodName added in v0.4.28

func (d *DeleteDistributionDescriptor) GetFullMethodName() string

func (*DeleteDistributionDescriptor) GetMethodName added in v0.4.28

func (d *DeleteDistributionDescriptor) GetMethodName() string

func (*DeleteDistributionDescriptor) GetProtoPkgName added in v0.4.28

func (d *DeleteDistributionDescriptor) GetProtoPkgName() string

func (*DeleteDistributionDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*DeleteDistributionDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*DeleteDistributionDescriptor) GetServiceDomain added in v0.4.28

func (d *DeleteDistributionDescriptor) GetServiceDomain() string

func (*DeleteDistributionDescriptor) GetServiceVersion added in v0.4.28

func (d *DeleteDistributionDescriptor) GetServiceVersion() string

func (*DeleteDistributionDescriptor) GetVerb added in v0.4.28

func (d *DeleteDistributionDescriptor) GetVerb() string

func (*DeleteDistributionDescriptor) HasResource added in v0.4.30

func (d *DeleteDistributionDescriptor) HasResource() bool

func (*DeleteDistributionDescriptor) IsClientStream added in v0.4.28

func (d *DeleteDistributionDescriptor) IsClientStream() bool

func (*DeleteDistributionDescriptor) IsCollection added in v0.4.30

func (d *DeleteDistributionDescriptor) IsCollection() bool

func (*DeleteDistributionDescriptor) IsPlural added in v0.4.30

func (d *DeleteDistributionDescriptor) IsPlural() bool

func (*DeleteDistributionDescriptor) IsServerStream added in v0.4.28

func (d *DeleteDistributionDescriptor) IsServerStream() bool

func (*DeleteDistributionDescriptor) IsUnary added in v0.4.28

func (d *DeleteDistributionDescriptor) IsUnary() bool

func (*DeleteDistributionDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*DeleteDistributionDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*DeleteDistributionDescriptor) RequestHasResourceBody added in v0.4.28

func (d *DeleteDistributionDescriptor) RequestHasResourceBody() bool

type DeleteDistributionDescriptorClientMsgHandle added in v0.4.28

type DeleteDistributionDescriptorClientMsgHandle struct{}

func (*DeleteDistributionDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*DeleteDistributionDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*DeleteDistributionDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*DeleteDistributionDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*DeleteDistributionDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type DeleteDistributionDescriptorServerMsgHandle added in v0.4.28

type DeleteDistributionDescriptorServerMsgHandle struct{}

func (*DeleteDistributionDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*DeleteDistributionDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*DeleteDistributionDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*DeleteDistributionDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*DeleteDistributionDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type DeleteDistributionRequest

type DeleteDistributionRequest struct {

	// Name of ntt.applications.v1alpha2.Distribution
	Name *distribution.Name `protobuf:"bytes,1,opt,customtype=Name,name=name,proto3" json:"name,omitempty" firestore:"name"`
	// contains filtered or unexported fields
}

A request message of the DeleteDistribution method.

func (*DeleteDistributionRequest) Descriptor

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

Deprecated, Use DeleteDistributionRequest.ProtoReflect.Descriptor instead.

func (*DeleteDistributionRequest) GetName

func (*DeleteDistributionRequest) GotenMessage

func (*DeleteDistributionRequest) GotenMessage()

func (*DeleteDistributionRequest) GotenValidate

func (obj *DeleteDistributionRequest) GotenValidate() error

func (*DeleteDistributionRequest) Marshal

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

func (*DeleteDistributionRequest) MarshalJSON

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

func (*DeleteDistributionRequest) ProtoMessage

func (*DeleteDistributionRequest) ProtoMessage()

func (*DeleteDistributionRequest) ProtoReflect

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

func (*DeleteDistributionRequest) Reset

func (m *DeleteDistributionRequest) Reset()

func (*DeleteDistributionRequest) SetName

func (*DeleteDistributionRequest) String

func (m *DeleteDistributionRequest) String() string

func (*DeleteDistributionRequest) Unmarshal

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

func (*DeleteDistributionRequest) UnmarshalJSON

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

type DistributionServiceClient

DistributionServiceClient is the client API for DistributionService.

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

type DistributionServiceDescriptor added in v0.4.28

type DistributionServiceDescriptor struct{}

func GetDistributionServiceDescriptor added in v0.4.28

func GetDistributionServiceDescriptor() *DistributionServiceDescriptor

func (*DistributionServiceDescriptor) AllMethodDescriptors added in v0.4.28

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

func (*DistributionServiceDescriptor) GetApiName added in v0.4.28

func (d *DistributionServiceDescriptor) GetApiName() string

func (*DistributionServiceDescriptor) GetFullAPIName added in v0.4.28

func (d *DistributionServiceDescriptor) GetFullAPIName() string

func (*DistributionServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *DistributionServiceDescriptor) GetProtoPkgName() string

func (*DistributionServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *DistributionServiceDescriptor) GetServiceDomain() string

func (*DistributionServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *DistributionServiceDescriptor) GetServiceVersion() string

type GetDistributionDescriptor added in v0.4.28

type GetDistributionDescriptor struct{}

func GetGetDistributionDescriptor added in v0.4.28

func GetGetDistributionDescriptor() *GetDistributionDescriptor

func (*GetDistributionDescriptor) GetApiDescriptor added in v0.4.28

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

func (*GetDistributionDescriptor) GetApiName added in v0.4.28

func (d *GetDistributionDescriptor) GetApiName() string

func (*GetDistributionDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*GetDistributionDescriptor) GetFullMethodName added in v0.4.28

func (d *GetDistributionDescriptor) GetFullMethodName() string

func (*GetDistributionDescriptor) GetMethodName added in v0.4.28

func (d *GetDistributionDescriptor) GetMethodName() string

func (*GetDistributionDescriptor) GetProtoPkgName added in v0.4.28

func (d *GetDistributionDescriptor) GetProtoPkgName() string

func (*GetDistributionDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*GetDistributionDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*GetDistributionDescriptor) GetServiceDomain added in v0.4.28

func (d *GetDistributionDescriptor) GetServiceDomain() string

func (*GetDistributionDescriptor) GetServiceVersion added in v0.4.28

func (d *GetDistributionDescriptor) GetServiceVersion() string

func (*GetDistributionDescriptor) GetVerb added in v0.4.28

func (d *GetDistributionDescriptor) GetVerb() string

func (*GetDistributionDescriptor) HasResource added in v0.4.30

func (d *GetDistributionDescriptor) HasResource() bool

func (*GetDistributionDescriptor) IsClientStream added in v0.4.28

func (d *GetDistributionDescriptor) IsClientStream() bool

func (*GetDistributionDescriptor) IsCollection added in v0.4.30

func (d *GetDistributionDescriptor) IsCollection() bool

func (*GetDistributionDescriptor) IsPlural added in v0.4.30

func (d *GetDistributionDescriptor) IsPlural() bool

func (*GetDistributionDescriptor) IsServerStream added in v0.4.28

func (d *GetDistributionDescriptor) IsServerStream() bool

func (*GetDistributionDescriptor) IsUnary added in v0.4.28

func (d *GetDistributionDescriptor) IsUnary() bool

func (*GetDistributionDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*GetDistributionDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*GetDistributionDescriptor) RequestHasResourceBody added in v0.4.28

func (d *GetDistributionDescriptor) RequestHasResourceBody() bool

type GetDistributionDescriptorClientMsgHandle added in v0.4.28

type GetDistributionDescriptorClientMsgHandle struct{}

func (*GetDistributionDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*GetDistributionDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetDistributionDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetDistributionDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*GetDistributionDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type GetDistributionDescriptorServerMsgHandle added in v0.4.28

type GetDistributionDescriptorServerMsgHandle struct{}

func (*GetDistributionDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*GetDistributionDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetDistributionDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetDistributionDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*GetDistributionDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type GetDistributionRequest

type GetDistributionRequest struct {

	// Name of ntt.applications.v1alpha2.Distribution
	Name *distribution.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 *distribution.Distribution_FieldMask `` /* 144-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
}

A request message of the GetDistribution method.

func (*GetDistributionRequest) Descriptor

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

Deprecated, Use GetDistributionRequest.ProtoReflect.Descriptor instead.

func (*GetDistributionRequest) GetFieldMask

func (*GetDistributionRequest) GetName

func (*GetDistributionRequest) GetView

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

func (*GetDistributionRequest) GotenMessage

func (*GetDistributionRequest) GotenMessage()

func (*GetDistributionRequest) GotenValidate

func (obj *GetDistributionRequest) GotenValidate() error

func (*GetDistributionRequest) Marshal

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

func (*GetDistributionRequest) MarshalJSON

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

func (*GetDistributionRequest) ProtoMessage

func (*GetDistributionRequest) ProtoMessage()

func (*GetDistributionRequest) ProtoReflect

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

func (*GetDistributionRequest) Reset

func (m *GetDistributionRequest) Reset()

func (*GetDistributionRequest) SetFieldMask

func (*GetDistributionRequest) SetName

func (m *GetDistributionRequest) SetName(fv *distribution.Name)

func (*GetDistributionRequest) SetView

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

func (*GetDistributionRequest) String

func (m *GetDistributionRequest) String() string

func (*GetDistributionRequest) Unmarshal

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

func (*GetDistributionRequest) UnmarshalJSON

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

type ListDistributionsDescriptor added in v0.4.28

type ListDistributionsDescriptor struct{}

func GetListDistributionsDescriptor added in v0.4.28

func GetListDistributionsDescriptor() *ListDistributionsDescriptor

func (*ListDistributionsDescriptor) GetApiDescriptor added in v0.4.28

func (*ListDistributionsDescriptor) GetApiName added in v0.4.28

func (d *ListDistributionsDescriptor) GetApiName() string

func (*ListDistributionsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*ListDistributionsDescriptor) GetFullMethodName added in v0.4.28

func (d *ListDistributionsDescriptor) GetFullMethodName() string

func (*ListDistributionsDescriptor) GetMethodName added in v0.4.28

func (d *ListDistributionsDescriptor) GetMethodName() string

func (*ListDistributionsDescriptor) GetProtoPkgName added in v0.4.28

func (d *ListDistributionsDescriptor) GetProtoPkgName() string

func (*ListDistributionsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*ListDistributionsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*ListDistributionsDescriptor) GetServiceDomain added in v0.4.28

func (d *ListDistributionsDescriptor) GetServiceDomain() string

func (*ListDistributionsDescriptor) GetServiceVersion added in v0.4.28

func (d *ListDistributionsDescriptor) GetServiceVersion() string

func (*ListDistributionsDescriptor) GetVerb added in v0.4.28

func (d *ListDistributionsDescriptor) GetVerb() string

func (*ListDistributionsDescriptor) HasResource added in v0.4.30

func (d *ListDistributionsDescriptor) HasResource() bool

func (*ListDistributionsDescriptor) IsClientStream added in v0.4.28

func (d *ListDistributionsDescriptor) IsClientStream() bool

func (*ListDistributionsDescriptor) IsCollection added in v0.4.30

func (d *ListDistributionsDescriptor) IsCollection() bool

func (*ListDistributionsDescriptor) IsPlural added in v0.4.30

func (d *ListDistributionsDescriptor) IsPlural() bool

func (*ListDistributionsDescriptor) IsServerStream added in v0.4.28

func (d *ListDistributionsDescriptor) IsServerStream() bool

func (*ListDistributionsDescriptor) IsUnary added in v0.4.28

func (d *ListDistributionsDescriptor) IsUnary() bool

func (*ListDistributionsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*ListDistributionsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*ListDistributionsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *ListDistributionsDescriptor) RequestHasResourceBody() bool

type ListDistributionsDescriptorClientMsgHandle added in v0.4.28

type ListDistributionsDescriptorClientMsgHandle struct{}

func (*ListDistributionsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListDistributionsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListDistributionsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListDistributionsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*ListDistributionsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type ListDistributionsDescriptorServerMsgHandle added in v0.4.28

type ListDistributionsDescriptorServerMsgHandle struct{}

func (*ListDistributionsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListDistributionsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListDistributionsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListDistributionsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*ListDistributionsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type ListDistributionsRequest

type ListDistributionsRequest struct {

	// Parent name of ntt.applications.v1alpha2.Distribution
	Parent *distribution.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Distributions 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
	// ListDistributionsResponse.next_page_token.
	PageToken *distribution.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 *distribution.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 *distribution.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 *distribution.Distribution_FieldMask `` /* 144-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
}

A request message of the ListDistributions method.

func (*ListDistributionsRequest) Descriptor

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

Deprecated, Use ListDistributionsRequest.ProtoReflect.Descriptor instead.

func (*ListDistributionsRequest) GetFieldMask

func (*ListDistributionsRequest) GetFilter

func (*ListDistributionsRequest) GetIncludePagingInfo added in v0.10.1

func (m *ListDistributionsRequest) GetIncludePagingInfo() bool

func (*ListDistributionsRequest) GetOrderBy

func (*ListDistributionsRequest) GetPageSize

func (m *ListDistributionsRequest) GetPageSize() int32

func (*ListDistributionsRequest) GetPageToken

func (*ListDistributionsRequest) GetParent

func (*ListDistributionsRequest) GetView

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

func (*ListDistributionsRequest) GotenMessage

func (*ListDistributionsRequest) GotenMessage()

func (*ListDistributionsRequest) GotenValidate

func (obj *ListDistributionsRequest) GotenValidate() error

func (*ListDistributionsRequest) Marshal

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

func (*ListDistributionsRequest) MarshalJSON

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

func (*ListDistributionsRequest) ProtoMessage

func (*ListDistributionsRequest) ProtoMessage()

func (*ListDistributionsRequest) ProtoReflect

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

func (*ListDistributionsRequest) Reset

func (m *ListDistributionsRequest) Reset()

func (*ListDistributionsRequest) SetFieldMask

func (*ListDistributionsRequest) SetFilter

func (m *ListDistributionsRequest) SetFilter(fv *distribution.Filter)

func (*ListDistributionsRequest) SetIncludePagingInfo added in v0.10.1

func (m *ListDistributionsRequest) SetIncludePagingInfo(fv bool)

func (*ListDistributionsRequest) SetOrderBy

func (m *ListDistributionsRequest) SetOrderBy(fv *distribution.OrderBy)

func (*ListDistributionsRequest) SetPageSize

func (m *ListDistributionsRequest) SetPageSize(fv int32)

func (*ListDistributionsRequest) SetPageToken

func (m *ListDistributionsRequest) SetPageToken(fv *distribution.PagerCursor)

func (*ListDistributionsRequest) SetParent

func (*ListDistributionsRequest) SetView

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

func (*ListDistributionsRequest) String

func (m *ListDistributionsRequest) String() string

func (*ListDistributionsRequest) Unmarshal

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

func (*ListDistributionsRequest) UnmarshalJSON

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

type ListDistributionsResponse

type ListDistributionsResponse struct {

	// The list of Distributions
	Distributions []*distribution.Distribution `protobuf:"bytes,1,rep,name=distributions,proto3" json:"distributions,omitempty" firestore:"distributions"`
	// A token to retrieve previous page of results.
	//
	// Pass this value in the ListDistributionsRequest.page_token.
	PrevPageToken *distribution.PagerCursor `` /* 151-byte string literal not displayed */
	// A token to retrieve next page of results.
	//
	// Pass this value in the ListDistributionsRequest.page_token.
	NextPageToken *distribution.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 Distributions 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
}

A response message of the ListDistributions method.

func (*ListDistributionsResponse) Descriptor

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

Deprecated, Use ListDistributionsResponse.ProtoReflect.Descriptor instead.

func (*ListDistributionsResponse) GetCurrentOffset added in v0.10.1

func (m *ListDistributionsResponse) GetCurrentOffset() int32

func (*ListDistributionsResponse) GetDistributions

func (m *ListDistributionsResponse) GetDistributions() []*distribution.Distribution

func (*ListDistributionsResponse) GetNextPageToken

func (m *ListDistributionsResponse) GetNextPageToken() *distribution.PagerCursor

func (*ListDistributionsResponse) GetPrevPageToken

func (m *ListDistributionsResponse) GetPrevPageToken() *distribution.PagerCursor

func (*ListDistributionsResponse) GetTotalResultsCount added in v0.10.1

func (m *ListDistributionsResponse) GetTotalResultsCount() int32

func (*ListDistributionsResponse) GotenMessage

func (*ListDistributionsResponse) GotenMessage()

func (*ListDistributionsResponse) GotenValidate

func (obj *ListDistributionsResponse) GotenValidate() error

func (*ListDistributionsResponse) Marshal

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

func (*ListDistributionsResponse) MarshalJSON

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

func (*ListDistributionsResponse) ProtoMessage

func (*ListDistributionsResponse) ProtoMessage()

func (*ListDistributionsResponse) ProtoReflect

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

func (*ListDistributionsResponse) Reset

func (m *ListDistributionsResponse) Reset()

func (*ListDistributionsResponse) SetCurrentOffset added in v0.10.1

func (m *ListDistributionsResponse) SetCurrentOffset(fv int32)

func (*ListDistributionsResponse) SetDistributions

func (m *ListDistributionsResponse) SetDistributions(fv []*distribution.Distribution)

func (*ListDistributionsResponse) SetNextPageToken

func (m *ListDistributionsResponse) SetNextPageToken(fv *distribution.PagerCursor)

func (*ListDistributionsResponse) SetPrevPageToken

func (m *ListDistributionsResponse) SetPrevPageToken(fv *distribution.PagerCursor)

func (*ListDistributionsResponse) SetTotalResultsCount added in v0.10.1

func (m *ListDistributionsResponse) SetTotalResultsCount(fv int32)

func (*ListDistributionsResponse) String

func (m *ListDistributionsResponse) String() string

func (*ListDistributionsResponse) Unmarshal

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

func (*ListDistributionsResponse) UnmarshalJSON

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

type UpdateDistributionDescriptor added in v0.4.28

type UpdateDistributionDescriptor struct{}

func GetUpdateDistributionDescriptor added in v0.4.28

func GetUpdateDistributionDescriptor() *UpdateDistributionDescriptor

func (*UpdateDistributionDescriptor) GetApiDescriptor added in v0.4.28

func (*UpdateDistributionDescriptor) GetApiName added in v0.4.28

func (d *UpdateDistributionDescriptor) GetApiName() string

func (*UpdateDistributionDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*UpdateDistributionDescriptor) GetFullMethodName added in v0.4.28

func (d *UpdateDistributionDescriptor) GetFullMethodName() string

func (*UpdateDistributionDescriptor) GetMethodName added in v0.4.28

func (d *UpdateDistributionDescriptor) GetMethodName() string

func (*UpdateDistributionDescriptor) GetProtoPkgName added in v0.4.28

func (d *UpdateDistributionDescriptor) GetProtoPkgName() string

func (*UpdateDistributionDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*UpdateDistributionDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*UpdateDistributionDescriptor) GetServiceDomain added in v0.4.28

func (d *UpdateDistributionDescriptor) GetServiceDomain() string

func (*UpdateDistributionDescriptor) GetServiceVersion added in v0.4.28

func (d *UpdateDistributionDescriptor) GetServiceVersion() string

func (*UpdateDistributionDescriptor) GetVerb added in v0.4.28

func (d *UpdateDistributionDescriptor) GetVerb() string

func (*UpdateDistributionDescriptor) HasResource added in v0.4.30

func (d *UpdateDistributionDescriptor) HasResource() bool

func (*UpdateDistributionDescriptor) IsClientStream added in v0.4.28

func (d *UpdateDistributionDescriptor) IsClientStream() bool

func (*UpdateDistributionDescriptor) IsCollection added in v0.4.30

func (d *UpdateDistributionDescriptor) IsCollection() bool

func (*UpdateDistributionDescriptor) IsPlural added in v0.4.30

func (d *UpdateDistributionDescriptor) IsPlural() bool

func (*UpdateDistributionDescriptor) IsServerStream added in v0.4.28

func (d *UpdateDistributionDescriptor) IsServerStream() bool

func (*UpdateDistributionDescriptor) IsUnary added in v0.4.28

func (d *UpdateDistributionDescriptor) IsUnary() bool

func (*UpdateDistributionDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*UpdateDistributionDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*UpdateDistributionDescriptor) RequestHasResourceBody added in v0.4.28

func (d *UpdateDistributionDescriptor) RequestHasResourceBody() bool

type UpdateDistributionDescriptorClientMsgHandle added in v0.4.28

type UpdateDistributionDescriptorClientMsgHandle struct{}

func (*UpdateDistributionDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*UpdateDistributionDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*UpdateDistributionDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*UpdateDistributionDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*UpdateDistributionDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type UpdateDistributionDescriptorServerMsgHandle added in v0.4.28

type UpdateDistributionDescriptorServerMsgHandle struct{}

func (*UpdateDistributionDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*UpdateDistributionDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*UpdateDistributionDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*UpdateDistributionDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*UpdateDistributionDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type UpdateDistributionRequest

type UpdateDistributionRequest struct {

	// Distribution resource body
	Distribution *distribution.Distribution `protobuf:"bytes,2,opt,name=distribution,proto3" json:"distribution,omitempty" firestore:"distribution"`
	// FieldMask applied to request - change will be applied only for fields in
	// the mask
	UpdateMask *distribution.Distribution_FieldMask `` /* 148-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 *UpdateDistributionRequest_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
}

A request message of the UpdateDistribution method.

func (*UpdateDistributionRequest) Descriptor

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

Deprecated, Use UpdateDistributionRequest.ProtoReflect.Descriptor instead.

func (*UpdateDistributionRequest) GetAllowMissing added in v0.12.33

func (m *UpdateDistributionRequest) GetAllowMissing() bool

func (*UpdateDistributionRequest) GetCas

func (*UpdateDistributionRequest) GetDistribution

func (m *UpdateDistributionRequest) GetDistribution() *distribution.Distribution

func (*UpdateDistributionRequest) GetUpdateMask

func (*UpdateDistributionRequest) GotenMessage

func (*UpdateDistributionRequest) GotenMessage()

func (*UpdateDistributionRequest) GotenValidate

func (obj *UpdateDistributionRequest) GotenValidate() error

func (*UpdateDistributionRequest) Marshal

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

func (*UpdateDistributionRequest) MarshalJSON

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

func (*UpdateDistributionRequest) ProtoMessage

func (*UpdateDistributionRequest) ProtoMessage()

func (*UpdateDistributionRequest) ProtoReflect

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

func (*UpdateDistributionRequest) Reset

func (m *UpdateDistributionRequest) Reset()

func (*UpdateDistributionRequest) SetAllowMissing added in v0.12.33

func (m *UpdateDistributionRequest) SetAllowMissing(fv bool)

func (*UpdateDistributionRequest) SetCas

func (*UpdateDistributionRequest) SetDistribution

func (m *UpdateDistributionRequest) SetDistribution(fv *distribution.Distribution)

func (*UpdateDistributionRequest) SetUpdateMask

func (*UpdateDistributionRequest) String

func (m *UpdateDistributionRequest) String() string

func (*UpdateDistributionRequest) Unmarshal

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

func (*UpdateDistributionRequest) UnmarshalJSON

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

type UpdateDistributionRequest_CAS

type UpdateDistributionRequest_CAS struct {

	// Conditional desired state of a resource before update.
	ConditionalState *distribution.Distribution `` /* 138-byte string literal not displayed */
	// Field paths from conditional state of resource server should check and
	// compare.
	FieldMask *distribution.Distribution_FieldMask `` /* 144-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 (*UpdateDistributionRequest_CAS) Descriptor

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

Deprecated, Use UpdateDistributionRequest_CAS.ProtoReflect.Descriptor instead.

func (*UpdateDistributionRequest_CAS) GetConditionalState

func (m *UpdateDistributionRequest_CAS) GetConditionalState() *distribution.Distribution

func (*UpdateDistributionRequest_CAS) GetFieldMask

func (*UpdateDistributionRequest_CAS) GotenMessage

func (*UpdateDistributionRequest_CAS) GotenMessage()

func (*UpdateDistributionRequest_CAS) GotenValidate

func (obj *UpdateDistributionRequest_CAS) GotenValidate() error

func (*UpdateDistributionRequest_CAS) Marshal

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

func (*UpdateDistributionRequest_CAS) MarshalJSON

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

func (*UpdateDistributionRequest_CAS) ProtoMessage

func (*UpdateDistributionRequest_CAS) ProtoMessage()

func (*UpdateDistributionRequest_CAS) ProtoReflect

func (*UpdateDistributionRequest_CAS) Reset

func (m *UpdateDistributionRequest_CAS) Reset()

func (*UpdateDistributionRequest_CAS) SetConditionalState

func (m *UpdateDistributionRequest_CAS) SetConditionalState(fv *distribution.Distribution)

func (*UpdateDistributionRequest_CAS) SetFieldMask

func (*UpdateDistributionRequest_CAS) String

func (*UpdateDistributionRequest_CAS) Unmarshal

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

func (*UpdateDistributionRequest_CAS) UnmarshalJSON

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

type WatchDistributionClientStream

type WatchDistributionClientStream interface {
	Recv() (*WatchDistributionResponse, error)
	grpc.ClientStream
}

type WatchDistributionDescriptor added in v0.4.28

type WatchDistributionDescriptor struct{}

func GetWatchDistributionDescriptor added in v0.4.28

func GetWatchDistributionDescriptor() *WatchDistributionDescriptor

func (*WatchDistributionDescriptor) GetApiDescriptor added in v0.4.28

func (*WatchDistributionDescriptor) GetApiName added in v0.4.28

func (d *WatchDistributionDescriptor) GetApiName() string

func (*WatchDistributionDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchDistributionDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchDistributionDescriptor) GetFullMethodName() string

func (*WatchDistributionDescriptor) GetMethodName added in v0.4.28

func (d *WatchDistributionDescriptor) GetMethodName() string

func (*WatchDistributionDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchDistributionDescriptor) GetProtoPkgName() string

func (*WatchDistributionDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchDistributionDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchDistributionDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchDistributionDescriptor) GetServiceDomain() string

func (*WatchDistributionDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchDistributionDescriptor) GetServiceVersion() string

func (*WatchDistributionDescriptor) GetVerb added in v0.4.28

func (d *WatchDistributionDescriptor) GetVerb() string

func (*WatchDistributionDescriptor) HasResource added in v0.4.30

func (d *WatchDistributionDescriptor) HasResource() bool

func (*WatchDistributionDescriptor) IsClientStream added in v0.4.28

func (d *WatchDistributionDescriptor) IsClientStream() bool

func (*WatchDistributionDescriptor) IsCollection added in v0.4.30

func (d *WatchDistributionDescriptor) IsCollection() bool

func (*WatchDistributionDescriptor) IsPlural added in v0.4.30

func (d *WatchDistributionDescriptor) IsPlural() bool

func (*WatchDistributionDescriptor) IsServerStream added in v0.4.28

func (d *WatchDistributionDescriptor) IsServerStream() bool

func (*WatchDistributionDescriptor) IsUnary added in v0.4.28

func (d *WatchDistributionDescriptor) IsUnary() bool

func (*WatchDistributionDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchDistributionDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchDistributionDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchDistributionDescriptor) RequestHasResourceBody() bool

type WatchDistributionDescriptorClientMsgHandle added in v0.4.28

type WatchDistributionDescriptorClientMsgHandle struct{}

func (*WatchDistributionDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchDistributionDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchDistributionDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchDistributionDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchDistributionDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchDistributionDescriptorServerMsgHandle added in v0.4.28

type WatchDistributionDescriptorServerMsgHandle struct{}

func (*WatchDistributionDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchDistributionDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchDistributionDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchDistributionDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchDistributionDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchDistributionRequest

type WatchDistributionRequest struct {

	// Name of ntt.applications.v1alpha2.Distribution
	Name *distribution.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 *distribution.Distribution_FieldMask `` /* 144-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
}

A request message of the WatchDistribution method.

func (*WatchDistributionRequest) Descriptor

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

Deprecated, Use WatchDistributionRequest.ProtoReflect.Descriptor instead.

func (*WatchDistributionRequest) GetFieldMask

func (*WatchDistributionRequest) GetName

func (*WatchDistributionRequest) GetView

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

func (*WatchDistributionRequest) GotenMessage

func (*WatchDistributionRequest) GotenMessage()

func (*WatchDistributionRequest) GotenValidate

func (obj *WatchDistributionRequest) GotenValidate() error

func (*WatchDistributionRequest) Marshal

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

func (*WatchDistributionRequest) MarshalJSON

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

func (*WatchDistributionRequest) ProtoMessage

func (*WatchDistributionRequest) ProtoMessage()

func (*WatchDistributionRequest) ProtoReflect

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

func (*WatchDistributionRequest) Reset

func (m *WatchDistributionRequest) Reset()

func (*WatchDistributionRequest) SetFieldMask

func (*WatchDistributionRequest) SetName

func (m *WatchDistributionRequest) SetName(fv *distribution.Name)

func (*WatchDistributionRequest) SetView

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

func (*WatchDistributionRequest) String

func (m *WatchDistributionRequest) String() string

func (*WatchDistributionRequest) Unmarshal

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

func (*WatchDistributionRequest) UnmarshalJSON

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

type WatchDistributionResponse

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

A response message of the WatchDistribution method.

func (*WatchDistributionResponse) Descriptor

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

Deprecated, Use WatchDistributionResponse.ProtoReflect.Descriptor instead.

func (*WatchDistributionResponse) GetChange

func (*WatchDistributionResponse) GotenMessage

func (*WatchDistributionResponse) GotenMessage()

func (*WatchDistributionResponse) GotenValidate

func (obj *WatchDistributionResponse) GotenValidate() error

func (*WatchDistributionResponse) Marshal

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

func (*WatchDistributionResponse) MarshalJSON

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

func (*WatchDistributionResponse) ProtoMessage

func (*WatchDistributionResponse) ProtoMessage()

func (*WatchDistributionResponse) ProtoReflect

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

func (*WatchDistributionResponse) Reset

func (m *WatchDistributionResponse) Reset()

func (*WatchDistributionResponse) SetChange

func (*WatchDistributionResponse) String

func (m *WatchDistributionResponse) String() string

func (*WatchDistributionResponse) Unmarshal

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

func (*WatchDistributionResponse) UnmarshalJSON

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

type WatchDistributionsClientStream

type WatchDistributionsClientStream interface {
	Recv() (*WatchDistributionsResponse, error)
	grpc.ClientStream
}

type WatchDistributionsDescriptor added in v0.4.28

type WatchDistributionsDescriptor struct{}

func GetWatchDistributionsDescriptor added in v0.4.28

func GetWatchDistributionsDescriptor() *WatchDistributionsDescriptor

func (*WatchDistributionsDescriptor) GetApiDescriptor added in v0.4.28

func (*WatchDistributionsDescriptor) GetApiName added in v0.4.28

func (d *WatchDistributionsDescriptor) GetApiName() string

func (*WatchDistributionsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchDistributionsDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchDistributionsDescriptor) GetFullMethodName() string

func (*WatchDistributionsDescriptor) GetMethodName added in v0.4.28

func (d *WatchDistributionsDescriptor) GetMethodName() string

func (*WatchDistributionsDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchDistributionsDescriptor) GetProtoPkgName() string

func (*WatchDistributionsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchDistributionsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchDistributionsDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchDistributionsDescriptor) GetServiceDomain() string

func (*WatchDistributionsDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchDistributionsDescriptor) GetServiceVersion() string

func (*WatchDistributionsDescriptor) GetVerb added in v0.4.28

func (d *WatchDistributionsDescriptor) GetVerb() string

func (*WatchDistributionsDescriptor) HasResource added in v0.4.30

func (d *WatchDistributionsDescriptor) HasResource() bool

func (*WatchDistributionsDescriptor) IsClientStream added in v0.4.28

func (d *WatchDistributionsDescriptor) IsClientStream() bool

func (*WatchDistributionsDescriptor) IsCollection added in v0.4.30

func (d *WatchDistributionsDescriptor) IsCollection() bool

func (*WatchDistributionsDescriptor) IsPlural added in v0.4.30

func (d *WatchDistributionsDescriptor) IsPlural() bool

func (*WatchDistributionsDescriptor) IsServerStream added in v0.4.28

func (d *WatchDistributionsDescriptor) IsServerStream() bool

func (*WatchDistributionsDescriptor) IsUnary added in v0.4.28

func (d *WatchDistributionsDescriptor) IsUnary() bool

func (*WatchDistributionsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchDistributionsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchDistributionsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchDistributionsDescriptor) RequestHasResourceBody() bool

type WatchDistributionsDescriptorClientMsgHandle added in v0.4.28

type WatchDistributionsDescriptorClientMsgHandle struct{}

func (*WatchDistributionsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchDistributionsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchDistributionsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchDistributionsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchDistributionsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchDistributionsDescriptorServerMsgHandle added in v0.4.28

type WatchDistributionsDescriptorServerMsgHandle struct{}

func (*WatchDistributionsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchDistributionsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchDistributionsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchDistributionsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchDistributionsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchDistributionsRequest

type WatchDistributionsRequest 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.applications.v1alpha2.Distribution
	Parent *distribution.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Distributions 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 *distribution.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 *distribution.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 *distribution.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 Distribution that don't
	// affect any of masked fields won't be sent back.
	FieldMask *distribution.Distribution_FieldMask `` /* 144-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
	// Distribution 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
}

A request message of the WatchDistributions method.

func (*WatchDistributionsRequest) Descriptor

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

Deprecated, Use WatchDistributionsRequest.ProtoReflect.Descriptor instead.

func (*WatchDistributionsRequest) GetFieldMask

func (*WatchDistributionsRequest) GetFilter

func (*WatchDistributionsRequest) GetMaxChunkSize

func (m *WatchDistributionsRequest) GetMaxChunkSize() int32

func (*WatchDistributionsRequest) GetOrderBy

func (*WatchDistributionsRequest) GetPageSize

func (m *WatchDistributionsRequest) GetPageSize() int32

func (*WatchDistributionsRequest) GetPageToken

func (*WatchDistributionsRequest) GetParent

func (*WatchDistributionsRequest) GetResumeToken

func (m *WatchDistributionsRequest) GetResumeToken() string

func (*WatchDistributionsRequest) GetStartingTime added in v0.9.0

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

func (*WatchDistributionsRequest) GetType

func (*WatchDistributionsRequest) GetView

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

func (*WatchDistributionsRequest) GotenMessage

func (*WatchDistributionsRequest) GotenMessage()

func (*WatchDistributionsRequest) GotenValidate

func (obj *WatchDistributionsRequest) GotenValidate() error

func (*WatchDistributionsRequest) Marshal

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

func (*WatchDistributionsRequest) MarshalJSON

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

func (*WatchDistributionsRequest) ProtoMessage

func (*WatchDistributionsRequest) ProtoMessage()

func (*WatchDistributionsRequest) ProtoReflect

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

func (*WatchDistributionsRequest) Reset

func (m *WatchDistributionsRequest) Reset()

func (*WatchDistributionsRequest) SetFieldMask

func (*WatchDistributionsRequest) SetFilter

func (m *WatchDistributionsRequest) SetFilter(fv *distribution.Filter)

func (*WatchDistributionsRequest) SetMaxChunkSize

func (m *WatchDistributionsRequest) SetMaxChunkSize(fv int32)

func (*WatchDistributionsRequest) SetOrderBy

func (m *WatchDistributionsRequest) SetOrderBy(fv *distribution.OrderBy)

func (*WatchDistributionsRequest) SetPageSize

func (m *WatchDistributionsRequest) SetPageSize(fv int32)

func (*WatchDistributionsRequest) SetPageToken

func (m *WatchDistributionsRequest) SetPageToken(fv *distribution.PagerCursor)

func (*WatchDistributionsRequest) SetParent

func (*WatchDistributionsRequest) SetResumeToken

func (m *WatchDistributionsRequest) SetResumeToken(fv string)

func (*WatchDistributionsRequest) SetStartingTime added in v0.9.0

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

func (*WatchDistributionsRequest) SetType

func (*WatchDistributionsRequest) SetView

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

func (*WatchDistributionsRequest) String

func (m *WatchDistributionsRequest) String() string

func (*WatchDistributionsRequest) Unmarshal

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

func (*WatchDistributionsRequest) UnmarshalJSON

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

type WatchDistributionsResponse

type WatchDistributionsResponse struct {

	// Changes of Distributions
	DistributionChanges []*distribution.DistributionChange `` /* 150-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 Distributions 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 *WatchDistributionsResponse_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 (Distributions 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
}

A response message of the WatchDistributions method.

func (*WatchDistributionsResponse) Descriptor

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

Deprecated, Use WatchDistributionsResponse.ProtoReflect.Descriptor instead.

func (*WatchDistributionsResponse) GetDistributionChanges

func (m *WatchDistributionsResponse) GetDistributionChanges() []*distribution.DistributionChange

func (*WatchDistributionsResponse) GetIsCurrent

func (m *WatchDistributionsResponse) GetIsCurrent() bool

func (*WatchDistributionsResponse) GetIsHardReset

func (m *WatchDistributionsResponse) GetIsHardReset() bool

func (*WatchDistributionsResponse) GetIsSoftReset

func (m *WatchDistributionsResponse) GetIsSoftReset() bool

func (*WatchDistributionsResponse) GetPageTokenChange

func (*WatchDistributionsResponse) GetResumeToken

func (m *WatchDistributionsResponse) GetResumeToken() string

func (*WatchDistributionsResponse) GetSnapshotSize

func (m *WatchDistributionsResponse) GetSnapshotSize() int64

func (*WatchDistributionsResponse) GotenMessage

func (*WatchDistributionsResponse) GotenMessage()

func (*WatchDistributionsResponse) GotenValidate

func (obj *WatchDistributionsResponse) GotenValidate() error

func (*WatchDistributionsResponse) Marshal

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

func (*WatchDistributionsResponse) MarshalJSON

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

func (*WatchDistributionsResponse) ProtoMessage

func (*WatchDistributionsResponse) ProtoMessage()

func (*WatchDistributionsResponse) ProtoReflect

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

func (*WatchDistributionsResponse) Reset

func (m *WatchDistributionsResponse) Reset()

func (*WatchDistributionsResponse) SetDistributionChanges

func (m *WatchDistributionsResponse) SetDistributionChanges(fv []*distribution.DistributionChange)

func (*WatchDistributionsResponse) SetIsCurrent

func (m *WatchDistributionsResponse) SetIsCurrent(fv bool)

func (*WatchDistributionsResponse) SetIsHardReset

func (m *WatchDistributionsResponse) SetIsHardReset(fv bool)

func (*WatchDistributionsResponse) SetIsSoftReset

func (m *WatchDistributionsResponse) SetIsSoftReset(fv bool)

func (*WatchDistributionsResponse) SetPageTokenChange

func (*WatchDistributionsResponse) SetResumeToken

func (m *WatchDistributionsResponse) SetResumeToken(fv string)

func (*WatchDistributionsResponse) SetSnapshotSize

func (m *WatchDistributionsResponse) SetSnapshotSize(fv int64)

func (*WatchDistributionsResponse) String

func (m *WatchDistributionsResponse) String() string

func (*WatchDistributionsResponse) Unmarshal

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

func (*WatchDistributionsResponse) UnmarshalJSON

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

type WatchDistributionsResponse_PageTokenChange

type WatchDistributionsResponse_PageTokenChange struct {

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

func (*WatchDistributionsResponse_PageTokenChange) Descriptor

Deprecated, Use WatchDistributionsResponse_PageTokenChange.ProtoReflect.Descriptor instead.

func (*WatchDistributionsResponse_PageTokenChange) GetNextPageToken

func (*WatchDistributionsResponse_PageTokenChange) GetPrevPageToken

func (*WatchDistributionsResponse_PageTokenChange) GotenMessage

func (*WatchDistributionsResponse_PageTokenChange) GotenValidate

func (*WatchDistributionsResponse_PageTokenChange) Marshal

func (*WatchDistributionsResponse_PageTokenChange) MarshalJSON

func (*WatchDistributionsResponse_PageTokenChange) ProtoMessage

func (*WatchDistributionsResponse_PageTokenChange) ProtoReflect

func (*WatchDistributionsResponse_PageTokenChange) Reset

func (*WatchDistributionsResponse_PageTokenChange) SetNextPageToken

func (*WatchDistributionsResponse_PageTokenChange) SetPrevPageToken

func (*WatchDistributionsResponse_PageTokenChange) String

func (*WatchDistributionsResponse_PageTokenChange) Unmarshal

func (*WatchDistributionsResponse_PageTokenChange) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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