pod_client

package
v1.5.12 Latest Latest
Warning

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

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

type BatchGetPodsDescriptor struct{}

func GetBatchGetPodsDescriptor added in v0.4.28

func GetBatchGetPodsDescriptor() *BatchGetPodsDescriptor

func (*BatchGetPodsDescriptor) GetApiDescriptor added in v0.4.28

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

func (*BatchGetPodsDescriptor) GetApiName added in v0.4.28

func (d *BatchGetPodsDescriptor) GetApiName() string

func (*BatchGetPodsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*BatchGetPodsDescriptor) GetFullMethodName added in v0.4.28

func (d *BatchGetPodsDescriptor) GetFullMethodName() string

func (*BatchGetPodsDescriptor) GetMethodName added in v0.4.28

func (d *BatchGetPodsDescriptor) GetMethodName() string

func (*BatchGetPodsDescriptor) GetProtoPkgName added in v0.4.28

func (d *BatchGetPodsDescriptor) GetProtoPkgName() string

func (*BatchGetPodsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*BatchGetPodsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*BatchGetPodsDescriptor) GetServiceDomain added in v0.4.28

func (d *BatchGetPodsDescriptor) GetServiceDomain() string

func (*BatchGetPodsDescriptor) GetServiceVersion added in v0.4.28

func (d *BatchGetPodsDescriptor) GetServiceVersion() string

func (*BatchGetPodsDescriptor) GetVerb added in v0.4.28

func (d *BatchGetPodsDescriptor) GetVerb() string

func (*BatchGetPodsDescriptor) HasResource added in v0.4.30

func (d *BatchGetPodsDescriptor) HasResource() bool

func (*BatchGetPodsDescriptor) IsClientStream added in v0.4.28

func (d *BatchGetPodsDescriptor) IsClientStream() bool

func (*BatchGetPodsDescriptor) IsCollection added in v0.4.30

func (d *BatchGetPodsDescriptor) IsCollection() bool

func (*BatchGetPodsDescriptor) IsPlural added in v0.4.30

func (d *BatchGetPodsDescriptor) IsPlural() bool

func (*BatchGetPodsDescriptor) IsServerStream added in v0.4.28

func (d *BatchGetPodsDescriptor) IsServerStream() bool

func (*BatchGetPodsDescriptor) IsUnary added in v0.4.28

func (d *BatchGetPodsDescriptor) IsUnary() bool

func (*BatchGetPodsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*BatchGetPodsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*BatchGetPodsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *BatchGetPodsDescriptor) RequestHasResourceBody() bool

type BatchGetPodsDescriptorClientMsgHandle added in v0.4.28

type BatchGetPodsDescriptorClientMsgHandle struct{}

func (*BatchGetPodsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetPodsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetPodsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetPodsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetPodsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetPodsDescriptorServerMsgHandle added in v0.4.28

type BatchGetPodsDescriptorServerMsgHandle struct{}

func (*BatchGetPodsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetPodsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetPodsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetPodsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetPodsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetPodsRequest

type BatchGetPodsRequest struct {

	// Names of Pods
	Names []*pod.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 *pod.Pod_FieldMask `` /* 135-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 BatchGetPods method.

func (*BatchGetPodsRequest) Descriptor

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

Deprecated, Use BatchGetPodsRequest.ProtoReflect.Descriptor instead.

func (*BatchGetPodsRequest) GetFieldMask

func (m *BatchGetPodsRequest) GetFieldMask() *pod.Pod_FieldMask

func (*BatchGetPodsRequest) GetNames

func (m *BatchGetPodsRequest) GetNames() []*pod.Name

func (*BatchGetPodsRequest) GetView

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

func (*BatchGetPodsRequest) GotenMessage

func (*BatchGetPodsRequest) GotenMessage()

func (*BatchGetPodsRequest) GotenValidate

func (obj *BatchGetPodsRequest) GotenValidate() error

func (*BatchGetPodsRequest) Marshal

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

func (*BatchGetPodsRequest) MarshalJSON

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

func (*BatchGetPodsRequest) ProtoMessage

func (*BatchGetPodsRequest) ProtoMessage()

func (*BatchGetPodsRequest) ProtoReflect

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

func (*BatchGetPodsRequest) Reset

func (m *BatchGetPodsRequest) Reset()

func (*BatchGetPodsRequest) SetFieldMask

func (m *BatchGetPodsRequest) SetFieldMask(fv *pod.Pod_FieldMask)

func (*BatchGetPodsRequest) SetNames

func (m *BatchGetPodsRequest) SetNames(fv []*pod.Name)

func (*BatchGetPodsRequest) SetView

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

func (*BatchGetPodsRequest) String

func (m *BatchGetPodsRequest) String() string

func (*BatchGetPodsRequest) Unmarshal

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

func (*BatchGetPodsRequest) UnmarshalJSON

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

type BatchGetPodsResponse

type BatchGetPodsResponse struct {

	// found Pods
	Pods []*pod.Pod `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty" firestore:"pods"`
	// list of not found Pods
	Missing []*pod.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 BatchGetPods method.

func (*BatchGetPodsResponse) Descriptor

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

Deprecated, Use BatchGetPodsResponse.ProtoReflect.Descriptor instead.

func (*BatchGetPodsResponse) GetMissing

func (m *BatchGetPodsResponse) GetMissing() []*pod.Name

func (*BatchGetPodsResponse) GetPods

func (m *BatchGetPodsResponse) GetPods() []*pod.Pod

func (*BatchGetPodsResponse) GotenMessage

func (*BatchGetPodsResponse) GotenMessage()

func (*BatchGetPodsResponse) GotenValidate

func (obj *BatchGetPodsResponse) GotenValidate() error

func (*BatchGetPodsResponse) Marshal

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

func (*BatchGetPodsResponse) MarshalJSON

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

func (*BatchGetPodsResponse) ProtoMessage

func (*BatchGetPodsResponse) ProtoMessage()

func (*BatchGetPodsResponse) ProtoReflect

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

func (*BatchGetPodsResponse) Reset

func (m *BatchGetPodsResponse) Reset()

func (*BatchGetPodsResponse) SetMissing

func (m *BatchGetPodsResponse) SetMissing(fv []*pod.Name)

func (*BatchGetPodsResponse) SetPods

func (m *BatchGetPodsResponse) SetPods(fv []*pod.Pod)

func (*BatchGetPodsResponse) String

func (m *BatchGetPodsResponse) String() string

func (*BatchGetPodsResponse) Unmarshal

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

func (*BatchGetPodsResponse) UnmarshalJSON

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

type CreatePodDescriptor added in v0.4.28

type CreatePodDescriptor struct{}

func GetCreatePodDescriptor added in v0.4.28

func GetCreatePodDescriptor() *CreatePodDescriptor

func (*CreatePodDescriptor) GetApiDescriptor added in v0.4.28

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

func (*CreatePodDescriptor) GetApiName added in v0.4.28

func (d *CreatePodDescriptor) GetApiName() string

func (*CreatePodDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*CreatePodDescriptor) GetFullMethodName added in v0.4.28

func (d *CreatePodDescriptor) GetFullMethodName() string

func (*CreatePodDescriptor) GetMethodName added in v0.4.28

func (d *CreatePodDescriptor) GetMethodName() string

func (*CreatePodDescriptor) GetProtoPkgName added in v0.4.28

func (d *CreatePodDescriptor) GetProtoPkgName() string

func (*CreatePodDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*CreatePodDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*CreatePodDescriptor) GetServiceDomain added in v0.4.28

func (d *CreatePodDescriptor) GetServiceDomain() string

func (*CreatePodDescriptor) GetServiceVersion added in v0.4.28

func (d *CreatePodDescriptor) GetServiceVersion() string

func (*CreatePodDescriptor) GetVerb added in v0.4.28

func (d *CreatePodDescriptor) GetVerb() string

func (*CreatePodDescriptor) HasResource added in v0.4.30

func (d *CreatePodDescriptor) HasResource() bool

func (*CreatePodDescriptor) IsClientStream added in v0.4.28

func (d *CreatePodDescriptor) IsClientStream() bool

func (*CreatePodDescriptor) IsCollection added in v0.4.30

func (d *CreatePodDescriptor) IsCollection() bool

func (*CreatePodDescriptor) IsPlural added in v0.4.30

func (d *CreatePodDescriptor) IsPlural() bool

func (*CreatePodDescriptor) IsServerStream added in v0.4.28

func (d *CreatePodDescriptor) IsServerStream() bool

func (*CreatePodDescriptor) IsUnary added in v0.4.28

func (d *CreatePodDescriptor) IsUnary() bool

func (*CreatePodDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*CreatePodDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*CreatePodDescriptor) RequestHasResourceBody added in v0.4.28

func (d *CreatePodDescriptor) RequestHasResourceBody() bool

type CreatePodDescriptorClientMsgHandle added in v0.4.28

type CreatePodDescriptorClientMsgHandle struct{}

func (*CreatePodDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*CreatePodDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*CreatePodDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*CreatePodDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*CreatePodDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type CreatePodDescriptorServerMsgHandle added in v0.4.28

type CreatePodDescriptorServerMsgHandle struct{}

func (*CreatePodDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*CreatePodDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*CreatePodDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*CreatePodDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*CreatePodDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type CreatePodRequest

type CreatePodRequest struct {

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

A request message of the CreatePod method.

func (*CreatePodRequest) Descriptor

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

Deprecated, Use CreatePodRequest.ProtoReflect.Descriptor instead.

func (*CreatePodRequest) GetParent

func (m *CreatePodRequest) GetParent() *pod.ParentName

func (*CreatePodRequest) GetPod

func (m *CreatePodRequest) GetPod() *pod.Pod

func (*CreatePodRequest) GotenMessage

func (*CreatePodRequest) GotenMessage()

func (*CreatePodRequest) GotenValidate

func (obj *CreatePodRequest) GotenValidate() error

func (*CreatePodRequest) Marshal

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

func (*CreatePodRequest) MarshalJSON

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

func (*CreatePodRequest) ProtoMessage

func (*CreatePodRequest) ProtoMessage()

func (*CreatePodRequest) ProtoReflect

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

func (*CreatePodRequest) Reset

func (m *CreatePodRequest) Reset()

func (*CreatePodRequest) SetParent

func (m *CreatePodRequest) SetParent(fv *pod.ParentName)

func (*CreatePodRequest) SetPod

func (m *CreatePodRequest) SetPod(fv *pod.Pod)

func (*CreatePodRequest) String

func (m *CreatePodRequest) String() string

func (*CreatePodRequest) Unmarshal

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

func (*CreatePodRequest) UnmarshalJSON

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

type DeletePodDescriptor added in v0.4.28

type DeletePodDescriptor struct{}

func GetDeletePodDescriptor added in v0.4.28

func GetDeletePodDescriptor() *DeletePodDescriptor

func (*DeletePodDescriptor) GetApiDescriptor added in v0.4.28

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

func (*DeletePodDescriptor) GetApiName added in v0.4.28

func (d *DeletePodDescriptor) GetApiName() string

func (*DeletePodDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*DeletePodDescriptor) GetFullMethodName added in v0.4.28

func (d *DeletePodDescriptor) GetFullMethodName() string

func (*DeletePodDescriptor) GetMethodName added in v0.4.28

func (d *DeletePodDescriptor) GetMethodName() string

func (*DeletePodDescriptor) GetProtoPkgName added in v0.4.28

func (d *DeletePodDescriptor) GetProtoPkgName() string

func (*DeletePodDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*DeletePodDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*DeletePodDescriptor) GetServiceDomain added in v0.4.28

func (d *DeletePodDescriptor) GetServiceDomain() string

func (*DeletePodDescriptor) GetServiceVersion added in v0.4.28

func (d *DeletePodDescriptor) GetServiceVersion() string

func (*DeletePodDescriptor) GetVerb added in v0.4.28

func (d *DeletePodDescriptor) GetVerb() string

func (*DeletePodDescriptor) HasResource added in v0.4.30

func (d *DeletePodDescriptor) HasResource() bool

func (*DeletePodDescriptor) IsClientStream added in v0.4.28

func (d *DeletePodDescriptor) IsClientStream() bool

func (*DeletePodDescriptor) IsCollection added in v0.4.30

func (d *DeletePodDescriptor) IsCollection() bool

func (*DeletePodDescriptor) IsPlural added in v0.4.30

func (d *DeletePodDescriptor) IsPlural() bool

func (*DeletePodDescriptor) IsServerStream added in v0.4.28

func (d *DeletePodDescriptor) IsServerStream() bool

func (*DeletePodDescriptor) IsUnary added in v0.4.28

func (d *DeletePodDescriptor) IsUnary() bool

func (*DeletePodDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*DeletePodDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*DeletePodDescriptor) RequestHasResourceBody added in v0.4.28

func (d *DeletePodDescriptor) RequestHasResourceBody() bool

type DeletePodDescriptorClientMsgHandle added in v0.4.28

type DeletePodDescriptorClientMsgHandle struct{}

func (*DeletePodDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*DeletePodDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*DeletePodDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*DeletePodDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*DeletePodDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type DeletePodDescriptorServerMsgHandle added in v0.4.28

type DeletePodDescriptorServerMsgHandle struct{}

func (*DeletePodDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*DeletePodDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*DeletePodDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*DeletePodDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*DeletePodDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type DeletePodRequest

type DeletePodRequest struct {

	// Name of ntt.applications.v1alpha2.Pod
	Name *pod.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 DeletePod method.

func (*DeletePodRequest) Descriptor

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

Deprecated, Use DeletePodRequest.ProtoReflect.Descriptor instead.

func (*DeletePodRequest) GetName

func (m *DeletePodRequest) GetName() *pod.Name

func (*DeletePodRequest) GotenMessage

func (*DeletePodRequest) GotenMessage()

func (*DeletePodRequest) GotenValidate

func (obj *DeletePodRequest) GotenValidate() error

func (*DeletePodRequest) Marshal

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

func (*DeletePodRequest) MarshalJSON

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

func (*DeletePodRequest) ProtoMessage

func (*DeletePodRequest) ProtoMessage()

func (*DeletePodRequest) ProtoReflect

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

func (*DeletePodRequest) Reset

func (m *DeletePodRequest) Reset()

func (*DeletePodRequest) SetName

func (m *DeletePodRequest) SetName(fv *pod.Name)

func (*DeletePodRequest) String

func (m *DeletePodRequest) String() string

func (*DeletePodRequest) Unmarshal

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

func (*DeletePodRequest) UnmarshalJSON

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

type GetPodDescriptor added in v0.4.28

type GetPodDescriptor struct{}

func GetGetPodDescriptor added in v0.4.28

func GetGetPodDescriptor() *GetPodDescriptor

func (*GetPodDescriptor) GetApiDescriptor added in v0.4.28

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

func (*GetPodDescriptor) GetApiName added in v0.4.28

func (d *GetPodDescriptor) GetApiName() string

func (*GetPodDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*GetPodDescriptor) GetFullMethodName added in v0.4.28

func (d *GetPodDescriptor) GetFullMethodName() string

func (*GetPodDescriptor) GetMethodName added in v0.4.28

func (d *GetPodDescriptor) GetMethodName() string

func (*GetPodDescriptor) GetProtoPkgName added in v0.4.28

func (d *GetPodDescriptor) GetProtoPkgName() string

func (*GetPodDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*GetPodDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*GetPodDescriptor) GetServiceDomain added in v0.4.28

func (d *GetPodDescriptor) GetServiceDomain() string

func (*GetPodDescriptor) GetServiceVersion added in v0.4.28

func (d *GetPodDescriptor) GetServiceVersion() string

func (*GetPodDescriptor) GetVerb added in v0.4.28

func (d *GetPodDescriptor) GetVerb() string

func (*GetPodDescriptor) HasResource added in v0.4.30

func (d *GetPodDescriptor) HasResource() bool

func (*GetPodDescriptor) IsClientStream added in v0.4.28

func (d *GetPodDescriptor) IsClientStream() bool

func (*GetPodDescriptor) IsCollection added in v0.4.30

func (d *GetPodDescriptor) IsCollection() bool

func (*GetPodDescriptor) IsPlural added in v0.4.30

func (d *GetPodDescriptor) IsPlural() bool

func (*GetPodDescriptor) IsServerStream added in v0.4.28

func (d *GetPodDescriptor) IsServerStream() bool

func (*GetPodDescriptor) IsUnary added in v0.4.28

func (d *GetPodDescriptor) IsUnary() bool

func (*GetPodDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*GetPodDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*GetPodDescriptor) RequestHasResourceBody added in v0.4.28

func (d *GetPodDescriptor) RequestHasResourceBody() bool

type GetPodDescriptorClientMsgHandle added in v0.4.28

type GetPodDescriptorClientMsgHandle struct{}

func (*GetPodDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*GetPodDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetPodDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetPodDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

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

func (*GetPodDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type GetPodDescriptorServerMsgHandle added in v0.4.28

type GetPodDescriptorServerMsgHandle struct{}

func (*GetPodDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*GetPodDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetPodDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetPodDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

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

func (*GetPodDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type GetPodRequest

type GetPodRequest struct {

	// Name of ntt.applications.v1alpha2.Pod
	Name *pod.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 *pod.Pod_FieldMask `` /* 135-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 GetPod method.

func (*GetPodRequest) Descriptor

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

Deprecated, Use GetPodRequest.ProtoReflect.Descriptor instead.

func (*GetPodRequest) GetFieldMask

func (m *GetPodRequest) GetFieldMask() *pod.Pod_FieldMask

func (*GetPodRequest) GetName

func (m *GetPodRequest) GetName() *pod.Name

func (*GetPodRequest) GetView

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

func (*GetPodRequest) GotenMessage

func (*GetPodRequest) GotenMessage()

func (*GetPodRequest) GotenValidate

func (obj *GetPodRequest) GotenValidate() error

func (*GetPodRequest) Marshal

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

func (*GetPodRequest) MarshalJSON

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

func (*GetPodRequest) ProtoMessage

func (*GetPodRequest) ProtoMessage()

func (*GetPodRequest) ProtoReflect

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

func (*GetPodRequest) Reset

func (m *GetPodRequest) Reset()

func (*GetPodRequest) SetFieldMask

func (m *GetPodRequest) SetFieldMask(fv *pod.Pod_FieldMask)

func (*GetPodRequest) SetName

func (m *GetPodRequest) SetName(fv *pod.Name)

func (*GetPodRequest) SetView

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

func (*GetPodRequest) String

func (m *GetPodRequest) String() string

func (*GetPodRequest) Unmarshal

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

func (*GetPodRequest) UnmarshalJSON

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

type ListPodsDescriptor added in v0.4.28

type ListPodsDescriptor struct{}

func GetListPodsDescriptor added in v0.4.28

func GetListPodsDescriptor() *ListPodsDescriptor

func (*ListPodsDescriptor) GetApiDescriptor added in v0.4.28

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

func (*ListPodsDescriptor) GetApiName added in v0.4.28

func (d *ListPodsDescriptor) GetApiName() string

func (*ListPodsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*ListPodsDescriptor) GetFullMethodName added in v0.4.28

func (d *ListPodsDescriptor) GetFullMethodName() string

func (*ListPodsDescriptor) GetMethodName added in v0.4.28

func (d *ListPodsDescriptor) GetMethodName() string

func (*ListPodsDescriptor) GetProtoPkgName added in v0.4.28

func (d *ListPodsDescriptor) GetProtoPkgName() string

func (*ListPodsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*ListPodsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*ListPodsDescriptor) GetServiceDomain added in v0.4.28

func (d *ListPodsDescriptor) GetServiceDomain() string

func (*ListPodsDescriptor) GetServiceVersion added in v0.4.28

func (d *ListPodsDescriptor) GetServiceVersion() string

func (*ListPodsDescriptor) GetVerb added in v0.4.28

func (d *ListPodsDescriptor) GetVerb() string

func (*ListPodsDescriptor) HasResource added in v0.4.30

func (d *ListPodsDescriptor) HasResource() bool

func (*ListPodsDescriptor) IsClientStream added in v0.4.28

func (d *ListPodsDescriptor) IsClientStream() bool

func (*ListPodsDescriptor) IsCollection added in v0.4.30

func (d *ListPodsDescriptor) IsCollection() bool

func (*ListPodsDescriptor) IsPlural added in v0.4.30

func (d *ListPodsDescriptor) IsPlural() bool

func (*ListPodsDescriptor) IsServerStream added in v0.4.28

func (d *ListPodsDescriptor) IsServerStream() bool

func (*ListPodsDescriptor) IsUnary added in v0.4.28

func (d *ListPodsDescriptor) IsUnary() bool

func (*ListPodsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*ListPodsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*ListPodsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *ListPodsDescriptor) RequestHasResourceBody() bool

type ListPodsDescriptorClientMsgHandle added in v0.4.28

type ListPodsDescriptorClientMsgHandle struct{}

func (*ListPodsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*ListPodsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListPodsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListPodsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*ListPodsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type ListPodsDescriptorServerMsgHandle added in v0.4.28

type ListPodsDescriptorServerMsgHandle struct{}

func (*ListPodsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*ListPodsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListPodsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListPodsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*ListPodsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type ListPodsRequest

type ListPodsRequest struct {

	// Parent name of ntt.applications.v1alpha2.Pod
	Parent *pod.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Pods 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
	// ListPodsResponse.next_page_token.
	PageToken *pod.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 *pod.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 *pod.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 *pod.Pod_FieldMask `` /* 135-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 ListPods method.

func (*ListPodsRequest) Descriptor

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

Deprecated, Use ListPodsRequest.ProtoReflect.Descriptor instead.

func (*ListPodsRequest) GetFieldMask

func (m *ListPodsRequest) GetFieldMask() *pod.Pod_FieldMask

func (*ListPodsRequest) GetFilter

func (m *ListPodsRequest) GetFilter() *pod.Filter

func (*ListPodsRequest) GetIncludePagingInfo added in v0.10.1

func (m *ListPodsRequest) GetIncludePagingInfo() bool

func (*ListPodsRequest) GetOrderBy

func (m *ListPodsRequest) GetOrderBy() *pod.OrderBy

func (*ListPodsRequest) GetPageSize

func (m *ListPodsRequest) GetPageSize() int32

func (*ListPodsRequest) GetPageToken

func (m *ListPodsRequest) GetPageToken() *pod.PagerCursor

func (*ListPodsRequest) GetParent

func (m *ListPodsRequest) GetParent() *pod.ParentName

func (*ListPodsRequest) GetView

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

func (*ListPodsRequest) GotenMessage

func (*ListPodsRequest) GotenMessage()

func (*ListPodsRequest) GotenValidate

func (obj *ListPodsRequest) GotenValidate() error

func (*ListPodsRequest) Marshal

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

func (*ListPodsRequest) MarshalJSON

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

func (*ListPodsRequest) ProtoMessage

func (*ListPodsRequest) ProtoMessage()

func (*ListPodsRequest) ProtoReflect

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

func (*ListPodsRequest) Reset

func (m *ListPodsRequest) Reset()

func (*ListPodsRequest) SetFieldMask

func (m *ListPodsRequest) SetFieldMask(fv *pod.Pod_FieldMask)

func (*ListPodsRequest) SetFilter

func (m *ListPodsRequest) SetFilter(fv *pod.Filter)

func (*ListPodsRequest) SetIncludePagingInfo added in v0.10.1

func (m *ListPodsRequest) SetIncludePagingInfo(fv bool)

func (*ListPodsRequest) SetOrderBy

func (m *ListPodsRequest) SetOrderBy(fv *pod.OrderBy)

func (*ListPodsRequest) SetPageSize

func (m *ListPodsRequest) SetPageSize(fv int32)

func (*ListPodsRequest) SetPageToken

func (m *ListPodsRequest) SetPageToken(fv *pod.PagerCursor)

func (*ListPodsRequest) SetParent

func (m *ListPodsRequest) SetParent(fv *pod.ParentName)

func (*ListPodsRequest) SetView

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

func (*ListPodsRequest) String

func (m *ListPodsRequest) String() string

func (*ListPodsRequest) Unmarshal

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

func (*ListPodsRequest) UnmarshalJSON

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

type ListPodsResponse

type ListPodsResponse struct {

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

func (*ListPodsResponse) Descriptor

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

Deprecated, Use ListPodsResponse.ProtoReflect.Descriptor instead.

func (*ListPodsResponse) GetCurrentOffset added in v0.10.1

func (m *ListPodsResponse) GetCurrentOffset() int32

func (*ListPodsResponse) GetNextPageToken

func (m *ListPodsResponse) GetNextPageToken() *pod.PagerCursor

func (*ListPodsResponse) GetPods

func (m *ListPodsResponse) GetPods() []*pod.Pod

func (*ListPodsResponse) GetPrevPageToken

func (m *ListPodsResponse) GetPrevPageToken() *pod.PagerCursor

func (*ListPodsResponse) GetTotalResultsCount added in v0.10.1

func (m *ListPodsResponse) GetTotalResultsCount() int32

func (*ListPodsResponse) GotenMessage

func (*ListPodsResponse) GotenMessage()

func (*ListPodsResponse) GotenValidate

func (obj *ListPodsResponse) GotenValidate() error

func (*ListPodsResponse) Marshal

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

func (*ListPodsResponse) MarshalJSON

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

func (*ListPodsResponse) ProtoMessage

func (*ListPodsResponse) ProtoMessage()

func (*ListPodsResponse) ProtoReflect

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

func (*ListPodsResponse) Reset

func (m *ListPodsResponse) Reset()

func (*ListPodsResponse) SetCurrentOffset added in v0.10.1

func (m *ListPodsResponse) SetCurrentOffset(fv int32)

func (*ListPodsResponse) SetNextPageToken

func (m *ListPodsResponse) SetNextPageToken(fv *pod.PagerCursor)

func (*ListPodsResponse) SetPods

func (m *ListPodsResponse) SetPods(fv []*pod.Pod)

func (*ListPodsResponse) SetPrevPageToken

func (m *ListPodsResponse) SetPrevPageToken(fv *pod.PagerCursor)

func (*ListPodsResponse) SetTotalResultsCount added in v0.10.1

func (m *ListPodsResponse) SetTotalResultsCount(fv int32)

func (*ListPodsResponse) String

func (m *ListPodsResponse) String() string

func (*ListPodsResponse) Unmarshal

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

func (*ListPodsResponse) UnmarshalJSON

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

type PodServiceClient

type PodServiceClient interface {
	GetPod(ctx context.Context, in *GetPodRequest, opts ...grpc.CallOption) (*pod.Pod, error)
	BatchGetPods(ctx context.Context, in *BatchGetPodsRequest, opts ...grpc.CallOption) (*BatchGetPodsResponse, error)
	ListPods(ctx context.Context, in *ListPodsRequest, opts ...grpc.CallOption) (*ListPodsResponse, error)
	WatchPod(ctx context.Context, in *WatchPodRequest, opts ...grpc.CallOption) (WatchPodClientStream, error)
	WatchPods(ctx context.Context, in *WatchPodsRequest, opts ...grpc.CallOption) (WatchPodsClientStream, error)
	CreatePod(ctx context.Context, in *CreatePodRequest, opts ...grpc.CallOption) (*pod.Pod, error)
	UpdatePod(ctx context.Context, in *UpdatePodRequest, opts ...grpc.CallOption) (*pod.Pod, error)
	DeletePod(ctx context.Context, in *DeletePodRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

PodServiceClient is the client API for PodService.

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

func NewPodServiceClient

func NewPodServiceClient(cc grpc.ClientConnInterface) PodServiceClient

type PodServiceDescriptor added in v0.4.28

type PodServiceDescriptor struct{}

func GetPodServiceDescriptor added in v0.4.28

func GetPodServiceDescriptor() *PodServiceDescriptor

func (*PodServiceDescriptor) AllMethodDescriptors added in v0.4.28

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

func (*PodServiceDescriptor) GetApiName added in v0.4.28

func (d *PodServiceDescriptor) GetApiName() string

func (*PodServiceDescriptor) GetFullAPIName added in v0.4.28

func (d *PodServiceDescriptor) GetFullAPIName() string

func (*PodServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *PodServiceDescriptor) GetProtoPkgName() string

func (*PodServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *PodServiceDescriptor) GetServiceDomain() string

func (*PodServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *PodServiceDescriptor) GetServiceVersion() string

type UpdatePodDescriptor added in v0.4.28

type UpdatePodDescriptor struct{}

func GetUpdatePodDescriptor added in v0.4.28

func GetUpdatePodDescriptor() *UpdatePodDescriptor

func (*UpdatePodDescriptor) GetApiDescriptor added in v0.4.28

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

func (*UpdatePodDescriptor) GetApiName added in v0.4.28

func (d *UpdatePodDescriptor) GetApiName() string

func (*UpdatePodDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*UpdatePodDescriptor) GetFullMethodName added in v0.4.28

func (d *UpdatePodDescriptor) GetFullMethodName() string

func (*UpdatePodDescriptor) GetMethodName added in v0.4.28

func (d *UpdatePodDescriptor) GetMethodName() string

func (*UpdatePodDescriptor) GetProtoPkgName added in v0.4.28

func (d *UpdatePodDescriptor) GetProtoPkgName() string

func (*UpdatePodDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*UpdatePodDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*UpdatePodDescriptor) GetServiceDomain added in v0.4.28

func (d *UpdatePodDescriptor) GetServiceDomain() string

func (*UpdatePodDescriptor) GetServiceVersion added in v0.4.28

func (d *UpdatePodDescriptor) GetServiceVersion() string

func (*UpdatePodDescriptor) GetVerb added in v0.4.28

func (d *UpdatePodDescriptor) GetVerb() string

func (*UpdatePodDescriptor) HasResource added in v0.4.30

func (d *UpdatePodDescriptor) HasResource() bool

func (*UpdatePodDescriptor) IsClientStream added in v0.4.28

func (d *UpdatePodDescriptor) IsClientStream() bool

func (*UpdatePodDescriptor) IsCollection added in v0.4.30

func (d *UpdatePodDescriptor) IsCollection() bool

func (*UpdatePodDescriptor) IsPlural added in v0.4.30

func (d *UpdatePodDescriptor) IsPlural() bool

func (*UpdatePodDescriptor) IsServerStream added in v0.4.28

func (d *UpdatePodDescriptor) IsServerStream() bool

func (*UpdatePodDescriptor) IsUnary added in v0.4.28

func (d *UpdatePodDescriptor) IsUnary() bool

func (*UpdatePodDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*UpdatePodDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*UpdatePodDescriptor) RequestHasResourceBody added in v0.4.28

func (d *UpdatePodDescriptor) RequestHasResourceBody() bool

type UpdatePodDescriptorClientMsgHandle added in v0.4.28

type UpdatePodDescriptorClientMsgHandle struct{}

func (*UpdatePodDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*UpdatePodDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*UpdatePodDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*UpdatePodDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*UpdatePodDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type UpdatePodDescriptorServerMsgHandle added in v0.4.28

type UpdatePodDescriptorServerMsgHandle struct{}

func (*UpdatePodDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*UpdatePodDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*UpdatePodDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*UpdatePodDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*UpdatePodDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type UpdatePodRequest

type UpdatePodRequest struct {

	// Pod resource body
	Pod *pod.Pod `protobuf:"bytes,2,opt,name=pod,proto3" json:"pod,omitempty" firestore:"pod"`
	// FieldMask applied to request - change will be applied only for fields in
	// the mask
	UpdateMask *pod.Pod_FieldMask `` /* 139-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 *UpdatePodRequest_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 UpdatePod method.

func (*UpdatePodRequest) Descriptor

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

Deprecated, Use UpdatePodRequest.ProtoReflect.Descriptor instead.

func (*UpdatePodRequest) GetAllowMissing added in v0.12.33

func (m *UpdatePodRequest) GetAllowMissing() bool

func (*UpdatePodRequest) GetCas

func (*UpdatePodRequest) GetPod

func (m *UpdatePodRequest) GetPod() *pod.Pod

func (*UpdatePodRequest) GetUpdateMask

func (m *UpdatePodRequest) GetUpdateMask() *pod.Pod_FieldMask

func (*UpdatePodRequest) GotenMessage

func (*UpdatePodRequest) GotenMessage()

func (*UpdatePodRequest) GotenValidate

func (obj *UpdatePodRequest) GotenValidate() error

func (*UpdatePodRequest) Marshal

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

func (*UpdatePodRequest) MarshalJSON

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

func (*UpdatePodRequest) ProtoMessage

func (*UpdatePodRequest) ProtoMessage()

func (*UpdatePodRequest) ProtoReflect

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

func (*UpdatePodRequest) Reset

func (m *UpdatePodRequest) Reset()

func (*UpdatePodRequest) SetAllowMissing added in v0.12.33

func (m *UpdatePodRequest) SetAllowMissing(fv bool)

func (*UpdatePodRequest) SetCas

func (m *UpdatePodRequest) SetCas(fv *UpdatePodRequest_CAS)

func (*UpdatePodRequest) SetPod

func (m *UpdatePodRequest) SetPod(fv *pod.Pod)

func (*UpdatePodRequest) SetUpdateMask

func (m *UpdatePodRequest) SetUpdateMask(fv *pod.Pod_FieldMask)

func (*UpdatePodRequest) String

func (m *UpdatePodRequest) String() string

func (*UpdatePodRequest) Unmarshal

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

func (*UpdatePodRequest) UnmarshalJSON

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

type UpdatePodRequest_CAS

type UpdatePodRequest_CAS struct {

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

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

Deprecated, Use UpdatePodRequest_CAS.ProtoReflect.Descriptor instead.

func (*UpdatePodRequest_CAS) GetConditionalState

func (m *UpdatePodRequest_CAS) GetConditionalState() *pod.Pod

func (*UpdatePodRequest_CAS) GetFieldMask

func (m *UpdatePodRequest_CAS) GetFieldMask() *pod.Pod_FieldMask

func (*UpdatePodRequest_CAS) GotenMessage

func (*UpdatePodRequest_CAS) GotenMessage()

func (*UpdatePodRequest_CAS) GotenValidate

func (obj *UpdatePodRequest_CAS) GotenValidate() error

func (*UpdatePodRequest_CAS) Marshal

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

func (*UpdatePodRequest_CAS) MarshalJSON

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

func (*UpdatePodRequest_CAS) ProtoMessage

func (*UpdatePodRequest_CAS) ProtoMessage()

func (*UpdatePodRequest_CAS) ProtoReflect

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

func (*UpdatePodRequest_CAS) Reset

func (m *UpdatePodRequest_CAS) Reset()

func (*UpdatePodRequest_CAS) SetConditionalState

func (m *UpdatePodRequest_CAS) SetConditionalState(fv *pod.Pod)

func (*UpdatePodRequest_CAS) SetFieldMask

func (m *UpdatePodRequest_CAS) SetFieldMask(fv *pod.Pod_FieldMask)

func (*UpdatePodRequest_CAS) String

func (m *UpdatePodRequest_CAS) String() string

func (*UpdatePodRequest_CAS) Unmarshal

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

func (*UpdatePodRequest_CAS) UnmarshalJSON

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

type WatchPodClientStream

type WatchPodClientStream interface {
	Recv() (*WatchPodResponse, error)
	grpc.ClientStream
}

type WatchPodDescriptor added in v0.4.28

type WatchPodDescriptor struct{}

func GetWatchPodDescriptor added in v0.4.28

func GetWatchPodDescriptor() *WatchPodDescriptor

func (*WatchPodDescriptor) GetApiDescriptor added in v0.4.28

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

func (*WatchPodDescriptor) GetApiName added in v0.4.28

func (d *WatchPodDescriptor) GetApiName() string

func (*WatchPodDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchPodDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchPodDescriptor) GetFullMethodName() string

func (*WatchPodDescriptor) GetMethodName added in v0.4.28

func (d *WatchPodDescriptor) GetMethodName() string

func (*WatchPodDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchPodDescriptor) GetProtoPkgName() string

func (*WatchPodDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchPodDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchPodDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchPodDescriptor) GetServiceDomain() string

func (*WatchPodDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchPodDescriptor) GetServiceVersion() string

func (*WatchPodDescriptor) GetVerb added in v0.4.28

func (d *WatchPodDescriptor) GetVerb() string

func (*WatchPodDescriptor) HasResource added in v0.4.30

func (d *WatchPodDescriptor) HasResource() bool

func (*WatchPodDescriptor) IsClientStream added in v0.4.28

func (d *WatchPodDescriptor) IsClientStream() bool

func (*WatchPodDescriptor) IsCollection added in v0.4.30

func (d *WatchPodDescriptor) IsCollection() bool

func (*WatchPodDescriptor) IsPlural added in v0.4.30

func (d *WatchPodDescriptor) IsPlural() bool

func (*WatchPodDescriptor) IsServerStream added in v0.4.28

func (d *WatchPodDescriptor) IsServerStream() bool

func (*WatchPodDescriptor) IsUnary added in v0.4.28

func (d *WatchPodDescriptor) IsUnary() bool

func (*WatchPodDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchPodDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchPodDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchPodDescriptor) RequestHasResourceBody() bool

type WatchPodDescriptorClientMsgHandle added in v0.4.28

type WatchPodDescriptorClientMsgHandle struct{}

func (*WatchPodDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*WatchPodDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchPodDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchPodDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchPodDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchPodDescriptorServerMsgHandle added in v0.4.28

type WatchPodDescriptorServerMsgHandle struct{}

func (*WatchPodDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*WatchPodDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchPodDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchPodDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchPodDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchPodRequest

type WatchPodRequest struct {

	// Name of ntt.applications.v1alpha2.Pod
	Name *pod.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 *pod.Pod_FieldMask `` /* 135-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 WatchPod method.

func (*WatchPodRequest) Descriptor

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

Deprecated, Use WatchPodRequest.ProtoReflect.Descriptor instead.

func (*WatchPodRequest) GetFieldMask

func (m *WatchPodRequest) GetFieldMask() *pod.Pod_FieldMask

func (*WatchPodRequest) GetName

func (m *WatchPodRequest) GetName() *pod.Name

func (*WatchPodRequest) GetView

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

func (*WatchPodRequest) GotenMessage

func (*WatchPodRequest) GotenMessage()

func (*WatchPodRequest) GotenValidate

func (obj *WatchPodRequest) GotenValidate() error

func (*WatchPodRequest) Marshal

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

func (*WatchPodRequest) MarshalJSON

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

func (*WatchPodRequest) ProtoMessage

func (*WatchPodRequest) ProtoMessage()

func (*WatchPodRequest) ProtoReflect

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

func (*WatchPodRequest) Reset

func (m *WatchPodRequest) Reset()

func (*WatchPodRequest) SetFieldMask

func (m *WatchPodRequest) SetFieldMask(fv *pod.Pod_FieldMask)

func (*WatchPodRequest) SetName

func (m *WatchPodRequest) SetName(fv *pod.Name)

func (*WatchPodRequest) SetView

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

func (*WatchPodRequest) String

func (m *WatchPodRequest) String() string

func (*WatchPodRequest) Unmarshal

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

func (*WatchPodRequest) UnmarshalJSON

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

type WatchPodResponse

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

A response message of the WatchPod method.

func (*WatchPodResponse) Descriptor

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

Deprecated, Use WatchPodResponse.ProtoReflect.Descriptor instead.

func (*WatchPodResponse) GetChange

func (m *WatchPodResponse) GetChange() *pod.PodChange

func (*WatchPodResponse) GotenMessage

func (*WatchPodResponse) GotenMessage()

func (*WatchPodResponse) GotenValidate

func (obj *WatchPodResponse) GotenValidate() error

func (*WatchPodResponse) Marshal

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

func (*WatchPodResponse) MarshalJSON

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

func (*WatchPodResponse) ProtoMessage

func (*WatchPodResponse) ProtoMessage()

func (*WatchPodResponse) ProtoReflect

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

func (*WatchPodResponse) Reset

func (m *WatchPodResponse) Reset()

func (*WatchPodResponse) SetChange

func (m *WatchPodResponse) SetChange(fv *pod.PodChange)

func (*WatchPodResponse) String

func (m *WatchPodResponse) String() string

func (*WatchPodResponse) Unmarshal

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

func (*WatchPodResponse) UnmarshalJSON

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

type WatchPodsClientStream

type WatchPodsClientStream interface {
	Recv() (*WatchPodsResponse, error)
	grpc.ClientStream
}

type WatchPodsDescriptor added in v0.4.28

type WatchPodsDescriptor struct{}

func GetWatchPodsDescriptor added in v0.4.28

func GetWatchPodsDescriptor() *WatchPodsDescriptor

func (*WatchPodsDescriptor) GetApiDescriptor added in v0.4.28

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

func (*WatchPodsDescriptor) GetApiName added in v0.4.28

func (d *WatchPodsDescriptor) GetApiName() string

func (*WatchPodsDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchPodsDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchPodsDescriptor) GetFullMethodName() string

func (*WatchPodsDescriptor) GetMethodName added in v0.4.28

func (d *WatchPodsDescriptor) GetMethodName() string

func (*WatchPodsDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchPodsDescriptor) GetProtoPkgName() string

func (*WatchPodsDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchPodsDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchPodsDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchPodsDescriptor) GetServiceDomain() string

func (*WatchPodsDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchPodsDescriptor) GetServiceVersion() string

func (*WatchPodsDescriptor) GetVerb added in v0.4.28

func (d *WatchPodsDescriptor) GetVerb() string

func (*WatchPodsDescriptor) HasResource added in v0.4.30

func (d *WatchPodsDescriptor) HasResource() bool

func (*WatchPodsDescriptor) IsClientStream added in v0.4.28

func (d *WatchPodsDescriptor) IsClientStream() bool

func (*WatchPodsDescriptor) IsCollection added in v0.4.30

func (d *WatchPodsDescriptor) IsCollection() bool

func (*WatchPodsDescriptor) IsPlural added in v0.4.30

func (d *WatchPodsDescriptor) IsPlural() bool

func (*WatchPodsDescriptor) IsServerStream added in v0.4.28

func (d *WatchPodsDescriptor) IsServerStream() bool

func (*WatchPodsDescriptor) IsUnary added in v0.4.28

func (d *WatchPodsDescriptor) IsUnary() bool

func (*WatchPodsDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchPodsDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchPodsDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchPodsDescriptor) RequestHasResourceBody() bool

type WatchPodsDescriptorClientMsgHandle added in v0.4.28

type WatchPodsDescriptorClientMsgHandle struct{}

func (*WatchPodsDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*WatchPodsDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchPodsDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchPodsDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchPodsDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchPodsDescriptorServerMsgHandle added in v0.4.28

type WatchPodsDescriptorServerMsgHandle struct{}

func (*WatchPodsDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*WatchPodsDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchPodsDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchPodsDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchPodsDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchPodsRequest

type WatchPodsRequest 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.Pod
	Parent *pod.ParentName `protobuf:"bytes,1,opt,customtype=ParentName,name=parent,proto3" json:"parent,omitempty" firestore:"parent"`
	// Requested page size. Server may return fewer Pods 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 *pod.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 *pod.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 *pod.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 Pod that don't affect any
	// of masked fields won't be sent back.
	FieldMask *pod.Pod_FieldMask `` /* 135-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 Pod
	// 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 WatchPods method.

func (*WatchPodsRequest) Descriptor

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

Deprecated, Use WatchPodsRequest.ProtoReflect.Descriptor instead.

func (*WatchPodsRequest) GetFieldMask

func (m *WatchPodsRequest) GetFieldMask() *pod.Pod_FieldMask

func (*WatchPodsRequest) GetFilter

func (m *WatchPodsRequest) GetFilter() *pod.Filter

func (*WatchPodsRequest) GetMaxChunkSize

func (m *WatchPodsRequest) GetMaxChunkSize() int32

func (*WatchPodsRequest) GetOrderBy

func (m *WatchPodsRequest) GetOrderBy() *pod.OrderBy

func (*WatchPodsRequest) GetPageSize

func (m *WatchPodsRequest) GetPageSize() int32

func (*WatchPodsRequest) GetPageToken

func (m *WatchPodsRequest) GetPageToken() *pod.PagerCursor

func (*WatchPodsRequest) GetParent

func (m *WatchPodsRequest) GetParent() *pod.ParentName

func (*WatchPodsRequest) GetResumeToken

func (m *WatchPodsRequest) GetResumeToken() string

func (*WatchPodsRequest) GetStartingTime added in v0.9.0

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

func (*WatchPodsRequest) GetType

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

func (*WatchPodsRequest) GetView

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

func (*WatchPodsRequest) GotenMessage

func (*WatchPodsRequest) GotenMessage()

func (*WatchPodsRequest) GotenValidate

func (obj *WatchPodsRequest) GotenValidate() error

func (*WatchPodsRequest) Marshal

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

func (*WatchPodsRequest) MarshalJSON

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

func (*WatchPodsRequest) ProtoMessage

func (*WatchPodsRequest) ProtoMessage()

func (*WatchPodsRequest) ProtoReflect

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

func (*WatchPodsRequest) Reset

func (m *WatchPodsRequest) Reset()

func (*WatchPodsRequest) SetFieldMask

func (m *WatchPodsRequest) SetFieldMask(fv *pod.Pod_FieldMask)

func (*WatchPodsRequest) SetFilter

func (m *WatchPodsRequest) SetFilter(fv *pod.Filter)

func (*WatchPodsRequest) SetMaxChunkSize

func (m *WatchPodsRequest) SetMaxChunkSize(fv int32)

func (*WatchPodsRequest) SetOrderBy

func (m *WatchPodsRequest) SetOrderBy(fv *pod.OrderBy)

func (*WatchPodsRequest) SetPageSize

func (m *WatchPodsRequest) SetPageSize(fv int32)

func (*WatchPodsRequest) SetPageToken

func (m *WatchPodsRequest) SetPageToken(fv *pod.PagerCursor)

func (*WatchPodsRequest) SetParent

func (m *WatchPodsRequest) SetParent(fv *pod.ParentName)

func (*WatchPodsRequest) SetResumeToken

func (m *WatchPodsRequest) SetResumeToken(fv string)

func (*WatchPodsRequest) SetStartingTime added in v0.9.0

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

func (*WatchPodsRequest) SetType

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

func (*WatchPodsRequest) SetView

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

func (*WatchPodsRequest) String

func (m *WatchPodsRequest) String() string

func (*WatchPodsRequest) Unmarshal

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

func (*WatchPodsRequest) UnmarshalJSON

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

type WatchPodsResponse

type WatchPodsResponse struct {

	// Changes of Pods
	PodChanges []*pod.PodChange `protobuf:"bytes,2,rep,name=pod_changes,json=podChanges,proto3" json:"pod_changes,omitempty" firestore:"podChanges"`
	// 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 Pods 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 *WatchPodsResponse_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 (Pods 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 WatchPods method.

func (*WatchPodsResponse) Descriptor

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

Deprecated, Use WatchPodsResponse.ProtoReflect.Descriptor instead.

func (*WatchPodsResponse) GetIsCurrent

func (m *WatchPodsResponse) GetIsCurrent() bool

func (*WatchPodsResponse) GetIsHardReset

func (m *WatchPodsResponse) GetIsHardReset() bool

func (*WatchPodsResponse) GetIsSoftReset

func (m *WatchPodsResponse) GetIsSoftReset() bool

func (*WatchPodsResponse) GetPageTokenChange

func (m *WatchPodsResponse) GetPageTokenChange() *WatchPodsResponse_PageTokenChange

func (*WatchPodsResponse) GetPodChanges

func (m *WatchPodsResponse) GetPodChanges() []*pod.PodChange

func (*WatchPodsResponse) GetResumeToken

func (m *WatchPodsResponse) GetResumeToken() string

func (*WatchPodsResponse) GetSnapshotSize

func (m *WatchPodsResponse) GetSnapshotSize() int64

func (*WatchPodsResponse) GotenMessage

func (*WatchPodsResponse) GotenMessage()

func (*WatchPodsResponse) GotenValidate

func (obj *WatchPodsResponse) GotenValidate() error

func (*WatchPodsResponse) Marshal

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

func (*WatchPodsResponse) MarshalJSON

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

func (*WatchPodsResponse) ProtoMessage

func (*WatchPodsResponse) ProtoMessage()

func (*WatchPodsResponse) ProtoReflect

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

func (*WatchPodsResponse) Reset

func (m *WatchPodsResponse) Reset()

func (*WatchPodsResponse) SetIsCurrent

func (m *WatchPodsResponse) SetIsCurrent(fv bool)

func (*WatchPodsResponse) SetIsHardReset

func (m *WatchPodsResponse) SetIsHardReset(fv bool)

func (*WatchPodsResponse) SetIsSoftReset

func (m *WatchPodsResponse) SetIsSoftReset(fv bool)

func (*WatchPodsResponse) SetPageTokenChange

func (m *WatchPodsResponse) SetPageTokenChange(fv *WatchPodsResponse_PageTokenChange)

func (*WatchPodsResponse) SetPodChanges

func (m *WatchPodsResponse) SetPodChanges(fv []*pod.PodChange)

func (*WatchPodsResponse) SetResumeToken

func (m *WatchPodsResponse) SetResumeToken(fv string)

func (*WatchPodsResponse) SetSnapshotSize

func (m *WatchPodsResponse) SetSnapshotSize(fv int64)

func (*WatchPodsResponse) String

func (m *WatchPodsResponse) String() string

func (*WatchPodsResponse) Unmarshal

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

func (*WatchPodsResponse) UnmarshalJSON

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

type WatchPodsResponse_PageTokenChange

type WatchPodsResponse_PageTokenChange struct {

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

func (*WatchPodsResponse_PageTokenChange) Descriptor

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

Deprecated, Use WatchPodsResponse_PageTokenChange.ProtoReflect.Descriptor instead.

func (*WatchPodsResponse_PageTokenChange) GetNextPageToken

func (m *WatchPodsResponse_PageTokenChange) GetNextPageToken() *pod.PagerCursor

func (*WatchPodsResponse_PageTokenChange) GetPrevPageToken

func (m *WatchPodsResponse_PageTokenChange) GetPrevPageToken() *pod.PagerCursor

func (*WatchPodsResponse_PageTokenChange) GotenMessage

func (*WatchPodsResponse_PageTokenChange) GotenMessage()

func (*WatchPodsResponse_PageTokenChange) GotenValidate

func (obj *WatchPodsResponse_PageTokenChange) GotenValidate() error

func (*WatchPodsResponse_PageTokenChange) Marshal

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

func (*WatchPodsResponse_PageTokenChange) MarshalJSON

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

func (*WatchPodsResponse_PageTokenChange) ProtoMessage

func (*WatchPodsResponse_PageTokenChange) ProtoMessage()

func (*WatchPodsResponse_PageTokenChange) ProtoReflect

func (*WatchPodsResponse_PageTokenChange) Reset

func (*WatchPodsResponse_PageTokenChange) SetNextPageToken

func (m *WatchPodsResponse_PageTokenChange) SetNextPageToken(fv *pod.PagerCursor)

func (*WatchPodsResponse_PageTokenChange) SetPrevPageToken

func (m *WatchPodsResponse_PageTokenChange) SetPrevPageToken(fv *pod.PagerCursor)

func (*WatchPodsResponse_PageTokenChange) String

func (*WatchPodsResponse_PageTokenChange) Unmarshal

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

func (*WatchPodsResponse_PageTokenChange) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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