service_client

package
v1.2.0 Latest Latest
Warning

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

Go to latest
Published: Jun 21, 2024 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchGetServicesDescriptor added in v0.4.28

type BatchGetServicesDescriptor struct{}

func GetBatchGetServicesDescriptor added in v0.4.28

func GetBatchGetServicesDescriptor() *BatchGetServicesDescriptor

func (*BatchGetServicesDescriptor) GetApiDescriptor added in v0.4.28

func (*BatchGetServicesDescriptor) GetApiName added in v0.4.28

func (d *BatchGetServicesDescriptor) GetApiName() string

func (*BatchGetServicesDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*BatchGetServicesDescriptor) GetFullMethodName added in v0.4.28

func (d *BatchGetServicesDescriptor) GetFullMethodName() string

func (*BatchGetServicesDescriptor) GetMethodName added in v0.4.28

func (d *BatchGetServicesDescriptor) GetMethodName() string

func (*BatchGetServicesDescriptor) GetProtoPkgName added in v0.4.28

func (d *BatchGetServicesDescriptor) GetProtoPkgName() string

func (*BatchGetServicesDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*BatchGetServicesDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*BatchGetServicesDescriptor) GetServiceDomain added in v0.4.28

func (d *BatchGetServicesDescriptor) GetServiceDomain() string

func (*BatchGetServicesDescriptor) GetServiceVersion added in v0.4.28

func (d *BatchGetServicesDescriptor) GetServiceVersion() string

func (*BatchGetServicesDescriptor) GetVerb added in v0.4.28

func (d *BatchGetServicesDescriptor) GetVerb() string

func (*BatchGetServicesDescriptor) HasResource added in v0.4.30

func (d *BatchGetServicesDescriptor) HasResource() bool

func (*BatchGetServicesDescriptor) IsClientStream added in v0.4.28

func (d *BatchGetServicesDescriptor) IsClientStream() bool

func (*BatchGetServicesDescriptor) IsCollection added in v0.4.30

func (d *BatchGetServicesDescriptor) IsCollection() bool

func (*BatchGetServicesDescriptor) IsPlural added in v0.4.30

func (d *BatchGetServicesDescriptor) IsPlural() bool

func (*BatchGetServicesDescriptor) IsServerStream added in v0.4.28

func (d *BatchGetServicesDescriptor) IsServerStream() bool

func (*BatchGetServicesDescriptor) IsUnary added in v0.4.28

func (d *BatchGetServicesDescriptor) IsUnary() bool

func (*BatchGetServicesDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*BatchGetServicesDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*BatchGetServicesDescriptor) RequestHasResourceBody added in v0.4.28

func (d *BatchGetServicesDescriptor) RequestHasResourceBody() bool

type BatchGetServicesDescriptorClientMsgHandle added in v0.4.28

type BatchGetServicesDescriptorClientMsgHandle struct{}

func (*BatchGetServicesDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetServicesDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetServicesDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetServicesDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetServicesDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetServicesDescriptorServerMsgHandle added in v0.4.28

type BatchGetServicesDescriptorServerMsgHandle struct{}

func (*BatchGetServicesDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*BatchGetServicesDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*BatchGetServicesDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*BatchGetServicesDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*BatchGetServicesDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type BatchGetServicesRequest

type BatchGetServicesRequest struct {

	// Names of Services
	Names []*service.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 *service.Service_FieldMask `` /* 139-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [BatchGetServices][ntt.meta.v1alpha2.BatchGetServices]

func (*BatchGetServicesRequest) Descriptor

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

Deprecated, Use BatchGetServicesRequest.ProtoReflect.Descriptor instead.

func (*BatchGetServicesRequest) GetFieldMask

func (*BatchGetServicesRequest) GetNames

func (m *BatchGetServicesRequest) GetNames() []*service.Name

func (*BatchGetServicesRequest) GetView

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

func (*BatchGetServicesRequest) GotenMessage

func (*BatchGetServicesRequest) GotenMessage()

func (*BatchGetServicesRequest) GotenValidate

func (obj *BatchGetServicesRequest) GotenValidate() error

func (*BatchGetServicesRequest) Marshal

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

func (*BatchGetServicesRequest) MarshalJSON

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

func (*BatchGetServicesRequest) ProtoMessage

func (*BatchGetServicesRequest) ProtoMessage()

func (*BatchGetServicesRequest) ProtoReflect

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

func (*BatchGetServicesRequest) Reset

func (m *BatchGetServicesRequest) Reset()

func (*BatchGetServicesRequest) SetFieldMask

func (m *BatchGetServicesRequest) SetFieldMask(fv *service.Service_FieldMask)

func (*BatchGetServicesRequest) SetNames

func (m *BatchGetServicesRequest) SetNames(fv []*service.Name)

func (*BatchGetServicesRequest) SetView

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

func (*BatchGetServicesRequest) String

func (m *BatchGetServicesRequest) String() string

func (*BatchGetServicesRequest) Unmarshal

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

func (*BatchGetServicesRequest) UnmarshalJSON

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

type BatchGetServicesResponse

type BatchGetServicesResponse struct {

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

BatchGetServicesResponse

func (*BatchGetServicesResponse) Descriptor

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

Deprecated, Use BatchGetServicesResponse.ProtoReflect.Descriptor instead.

func (*BatchGetServicesResponse) GetMissing

func (m *BatchGetServicesResponse) GetMissing() []*service.Name

func (*BatchGetServicesResponse) GetServices

func (m *BatchGetServicesResponse) GetServices() []*service.Service

func (*BatchGetServicesResponse) GotenMessage

func (*BatchGetServicesResponse) GotenMessage()

func (*BatchGetServicesResponse) GotenValidate

func (obj *BatchGetServicesResponse) GotenValidate() error

func (*BatchGetServicesResponse) Marshal

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

func (*BatchGetServicesResponse) MarshalJSON

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

func (*BatchGetServicesResponse) ProtoMessage

func (*BatchGetServicesResponse) ProtoMessage()

func (*BatchGetServicesResponse) ProtoReflect

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

func (*BatchGetServicesResponse) Reset

func (m *BatchGetServicesResponse) Reset()

func (*BatchGetServicesResponse) SetMissing

func (m *BatchGetServicesResponse) SetMissing(fv []*service.Name)

func (*BatchGetServicesResponse) SetServices

func (m *BatchGetServicesResponse) SetServices(fv []*service.Service)

func (*BatchGetServicesResponse) String

func (m *BatchGetServicesResponse) String() string

func (*BatchGetServicesResponse) Unmarshal

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

func (*BatchGetServicesResponse) UnmarshalJSON

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

type GetServiceDescriptor added in v0.4.28

type GetServiceDescriptor struct{}

func GetGetServiceDescriptor added in v0.4.28

func GetGetServiceDescriptor() *GetServiceDescriptor

func (*GetServiceDescriptor) GetApiDescriptor added in v0.4.28

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

func (*GetServiceDescriptor) GetApiName added in v0.4.28

func (d *GetServiceDescriptor) GetApiName() string

func (*GetServiceDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*GetServiceDescriptor) GetFullMethodName added in v0.4.28

func (d *GetServiceDescriptor) GetFullMethodName() string

func (*GetServiceDescriptor) GetMethodName added in v0.4.28

func (d *GetServiceDescriptor) GetMethodName() string

func (*GetServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *GetServiceDescriptor) GetProtoPkgName() string

func (*GetServiceDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*GetServiceDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*GetServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *GetServiceDescriptor) GetServiceDomain() string

func (*GetServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *GetServiceDescriptor) GetServiceVersion() string

func (*GetServiceDescriptor) GetVerb added in v0.4.28

func (d *GetServiceDescriptor) GetVerb() string

func (*GetServiceDescriptor) HasResource added in v0.4.30

func (d *GetServiceDescriptor) HasResource() bool

func (*GetServiceDescriptor) IsClientStream added in v0.4.28

func (d *GetServiceDescriptor) IsClientStream() bool

func (*GetServiceDescriptor) IsCollection added in v0.4.30

func (d *GetServiceDescriptor) IsCollection() bool

func (*GetServiceDescriptor) IsPlural added in v0.4.30

func (d *GetServiceDescriptor) IsPlural() bool

func (*GetServiceDescriptor) IsServerStream added in v0.4.28

func (d *GetServiceDescriptor) IsServerStream() bool

func (*GetServiceDescriptor) IsUnary added in v0.4.28

func (d *GetServiceDescriptor) IsUnary() bool

func (*GetServiceDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*GetServiceDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*GetServiceDescriptor) RequestHasResourceBody added in v0.4.28

func (d *GetServiceDescriptor) RequestHasResourceBody() bool

type GetServiceDescriptorClientMsgHandle added in v0.4.28

type GetServiceDescriptorClientMsgHandle struct{}

func (*GetServiceDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*GetServiceDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetServiceDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetServiceDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*GetServiceDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type GetServiceDescriptorServerMsgHandle added in v0.4.28

type GetServiceDescriptorServerMsgHandle struct{}

func (*GetServiceDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

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

func (*GetServiceDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*GetServiceDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*GetServiceDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*GetServiceDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type GetServiceRequest

type GetServiceRequest struct {

	// Name of ntt.meta.v1alpha2.Service
	Name *service.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 *service.Service_FieldMask `` /* 139-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [GetService][ntt.meta.v1alpha2.GetService]

func (*GetServiceRequest) Descriptor

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

Deprecated, Use GetServiceRequest.ProtoReflect.Descriptor instead.

func (*GetServiceRequest) GetFieldMask

func (m *GetServiceRequest) GetFieldMask() *service.Service_FieldMask

func (*GetServiceRequest) GetName

func (m *GetServiceRequest) GetName() *service.Name

func (*GetServiceRequest) GetView

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

func (*GetServiceRequest) GotenMessage

func (*GetServiceRequest) GotenMessage()

func (*GetServiceRequest) GotenValidate

func (obj *GetServiceRequest) GotenValidate() error

func (*GetServiceRequest) Marshal

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

func (*GetServiceRequest) MarshalJSON

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

func (*GetServiceRequest) ProtoMessage

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) ProtoReflect

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

func (*GetServiceRequest) Reset

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) SetFieldMask

func (m *GetServiceRequest) SetFieldMask(fv *service.Service_FieldMask)

func (*GetServiceRequest) SetName

func (m *GetServiceRequest) SetName(fv *service.Name)

func (*GetServiceRequest) SetView

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

func (*GetServiceRequest) String

func (m *GetServiceRequest) String() string

func (*GetServiceRequest) Unmarshal

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

func (*GetServiceRequest) UnmarshalJSON

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

type ListServicesDescriptor added in v0.4.28

type ListServicesDescriptor struct{}

func GetListServicesDescriptor added in v0.4.28

func GetListServicesDescriptor() *ListServicesDescriptor

func (*ListServicesDescriptor) GetApiDescriptor added in v0.4.28

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

func (*ListServicesDescriptor) GetApiName added in v0.4.28

func (d *ListServicesDescriptor) GetApiName() string

func (*ListServicesDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*ListServicesDescriptor) GetFullMethodName added in v0.4.28

func (d *ListServicesDescriptor) GetFullMethodName() string

func (*ListServicesDescriptor) GetMethodName added in v0.4.28

func (d *ListServicesDescriptor) GetMethodName() string

func (*ListServicesDescriptor) GetProtoPkgName added in v0.4.28

func (d *ListServicesDescriptor) GetProtoPkgName() string

func (*ListServicesDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*ListServicesDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*ListServicesDescriptor) GetServiceDomain added in v0.4.28

func (d *ListServicesDescriptor) GetServiceDomain() string

func (*ListServicesDescriptor) GetServiceVersion added in v0.4.28

func (d *ListServicesDescriptor) GetServiceVersion() string

func (*ListServicesDescriptor) GetVerb added in v0.4.28

func (d *ListServicesDescriptor) GetVerb() string

func (*ListServicesDescriptor) HasResource added in v0.4.30

func (d *ListServicesDescriptor) HasResource() bool

func (*ListServicesDescriptor) IsClientStream added in v0.4.28

func (d *ListServicesDescriptor) IsClientStream() bool

func (*ListServicesDescriptor) IsCollection added in v0.4.30

func (d *ListServicesDescriptor) IsCollection() bool

func (*ListServicesDescriptor) IsPlural added in v0.4.30

func (d *ListServicesDescriptor) IsPlural() bool

func (*ListServicesDescriptor) IsServerStream added in v0.4.28

func (d *ListServicesDescriptor) IsServerStream() bool

func (*ListServicesDescriptor) IsUnary added in v0.4.28

func (d *ListServicesDescriptor) IsUnary() bool

func (*ListServicesDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*ListServicesDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*ListServicesDescriptor) RequestHasResourceBody added in v0.4.28

func (d *ListServicesDescriptor) RequestHasResourceBody() bool

type ListServicesDescriptorClientMsgHandle added in v0.4.28

type ListServicesDescriptorClientMsgHandle struct{}

func (*ListServicesDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListServicesDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListServicesDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListServicesDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*ListServicesDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type ListServicesDescriptorServerMsgHandle added in v0.4.28

type ListServicesDescriptorServerMsgHandle struct{}

func (*ListServicesDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*ListServicesDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*ListServicesDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*ListServicesDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*ListServicesDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type ListServicesRequest

type ListServicesRequest struct {

	// Requested page size. Server may return fewer Services 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
	// [ListServicesResponse.next_page_token][ntt.meta.v1alpha2.ListServicesResponse.next_page_token]
	PageToken *service.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 *service.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 *service.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 *service.Service_FieldMask `` /* 139-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,7,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// Indicates if list response should contain total count and offset (fields
	// current_offset and total_results_count).
	IncludePagingInfo bool `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [ListServices][ntt.meta.v1alpha2.ListServices]

func (*ListServicesRequest) Descriptor

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

Deprecated, Use ListServicesRequest.ProtoReflect.Descriptor instead.

func (*ListServicesRequest) GetFieldMask

func (m *ListServicesRequest) GetFieldMask() *service.Service_FieldMask

func (*ListServicesRequest) GetFilter

func (m *ListServicesRequest) GetFilter() *service.Filter

func (*ListServicesRequest) GetIncludePagingInfo added in v0.10.1

func (m *ListServicesRequest) GetIncludePagingInfo() bool

func (*ListServicesRequest) GetOrderBy

func (m *ListServicesRequest) GetOrderBy() *service.OrderBy

func (*ListServicesRequest) GetPageSize

func (m *ListServicesRequest) GetPageSize() int32

func (*ListServicesRequest) GetPageToken

func (m *ListServicesRequest) GetPageToken() *service.PagerCursor

func (*ListServicesRequest) GetView

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

func (*ListServicesRequest) GotenMessage

func (*ListServicesRequest) GotenMessage()

func (*ListServicesRequest) GotenValidate

func (obj *ListServicesRequest) GotenValidate() error

func (*ListServicesRequest) Marshal

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

func (*ListServicesRequest) MarshalJSON

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

func (*ListServicesRequest) ProtoMessage

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) ProtoReflect

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

func (*ListServicesRequest) Reset

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) SetFieldMask

func (m *ListServicesRequest) SetFieldMask(fv *service.Service_FieldMask)

func (*ListServicesRequest) SetFilter

func (m *ListServicesRequest) SetFilter(fv *service.Filter)

func (*ListServicesRequest) SetIncludePagingInfo added in v0.10.1

func (m *ListServicesRequest) SetIncludePagingInfo(fv bool)

func (*ListServicesRequest) SetOrderBy

func (m *ListServicesRequest) SetOrderBy(fv *service.OrderBy)

func (*ListServicesRequest) SetPageSize

func (m *ListServicesRequest) SetPageSize(fv int32)

func (*ListServicesRequest) SetPageToken

func (m *ListServicesRequest) SetPageToken(fv *service.PagerCursor)

func (*ListServicesRequest) SetView

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

func (*ListServicesRequest) String

func (m *ListServicesRequest) String() string

func (*ListServicesRequest) Unmarshal

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

func (*ListServicesRequest) UnmarshalJSON

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

type ListServicesResponse

type ListServicesResponse struct {

	// The list of Services
	Services []*service.Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty" firestore:"services"`
	// A token to retrieve previous page of results. Pass this value in the
	// [ListServicesRequest.page_token][ntt.meta.v1alpha2.ListServicesRequest.page_token]
	PrevPageToken *service.PagerCursor `` /* 151-byte string literal not displayed */
	// A token to retrieve next page of results. Pass this value in the
	// [ListServicesRequest.page_token][ntt.meta.v1alpha2.ListServicesRequest.page_token]
	NextPageToken *service.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 Services across all pages or 0, if there are no items,
	// paging info was not requested or there was an error while trying to get it.
	TotalResultsCount int32 `` /* 145-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [ListServices][ntt.meta.v1alpha2.ListServices]

func (*ListServicesResponse) Descriptor

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

Deprecated, Use ListServicesResponse.ProtoReflect.Descriptor instead.

func (*ListServicesResponse) GetCurrentOffset added in v0.10.1

func (m *ListServicesResponse) GetCurrentOffset() int32

func (*ListServicesResponse) GetNextPageToken

func (m *ListServicesResponse) GetNextPageToken() *service.PagerCursor

func (*ListServicesResponse) GetPrevPageToken

func (m *ListServicesResponse) GetPrevPageToken() *service.PagerCursor

func (*ListServicesResponse) GetServices

func (m *ListServicesResponse) GetServices() []*service.Service

func (*ListServicesResponse) GetTotalResultsCount added in v0.10.1

func (m *ListServicesResponse) GetTotalResultsCount() int32

func (*ListServicesResponse) GotenMessage

func (*ListServicesResponse) GotenMessage()

func (*ListServicesResponse) GotenValidate

func (obj *ListServicesResponse) GotenValidate() error

func (*ListServicesResponse) Marshal

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

func (*ListServicesResponse) MarshalJSON

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

func (*ListServicesResponse) ProtoMessage

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) ProtoReflect

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

func (*ListServicesResponse) Reset

func (m *ListServicesResponse) Reset()

func (*ListServicesResponse) SetCurrentOffset added in v0.10.1

func (m *ListServicesResponse) SetCurrentOffset(fv int32)

func (*ListServicesResponse) SetNextPageToken

func (m *ListServicesResponse) SetNextPageToken(fv *service.PagerCursor)

func (*ListServicesResponse) SetPrevPageToken

func (m *ListServicesResponse) SetPrevPageToken(fv *service.PagerCursor)

func (*ListServicesResponse) SetServices

func (m *ListServicesResponse) SetServices(fv []*service.Service)

func (*ListServicesResponse) SetTotalResultsCount added in v0.10.1

func (m *ListServicesResponse) SetTotalResultsCount(fv int32)

func (*ListServicesResponse) String

func (m *ListServicesResponse) String() string

func (*ListServicesResponse) Unmarshal

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

func (*ListServicesResponse) UnmarshalJSON

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

type ServiceServiceClient

type ServiceServiceClient interface {
	GetService(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*service.Service, error)
	BatchGetServices(ctx context.Context, in *BatchGetServicesRequest, opts ...grpc.CallOption) (*BatchGetServicesResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...grpc.CallOption) (*ListServicesResponse, error)
	WatchService(ctx context.Context, in *WatchServiceRequest, opts ...grpc.CallOption) (WatchServiceClientStream, error)
	WatchServices(ctx context.Context, in *WatchServicesRequest, opts ...grpc.CallOption) (WatchServicesClientStream, error)
}

ServiceServiceClient is the client API for ServiceService.

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

type ServiceServiceDescriptor added in v0.4.28

type ServiceServiceDescriptor struct{}

func GetServiceServiceDescriptor added in v0.4.28

func GetServiceServiceDescriptor() *ServiceServiceDescriptor

func (*ServiceServiceDescriptor) AllMethodDescriptors added in v0.4.28

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

func (*ServiceServiceDescriptor) GetApiName added in v0.4.28

func (d *ServiceServiceDescriptor) GetApiName() string

func (*ServiceServiceDescriptor) GetFullAPIName added in v0.4.28

func (d *ServiceServiceDescriptor) GetFullAPIName() string

func (*ServiceServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *ServiceServiceDescriptor) GetProtoPkgName() string

func (*ServiceServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *ServiceServiceDescriptor) GetServiceDomain() string

func (*ServiceServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *ServiceServiceDescriptor) GetServiceVersion() string

type WatchServiceClientStream

type WatchServiceClientStream interface {
	Recv() (*WatchServiceResponse, error)
	grpc.ClientStream
}

type WatchServiceDescriptor added in v0.4.28

type WatchServiceDescriptor struct{}

func GetWatchServiceDescriptor added in v0.4.28

func GetWatchServiceDescriptor() *WatchServiceDescriptor

func (*WatchServiceDescriptor) GetApiDescriptor added in v0.4.28

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

func (*WatchServiceDescriptor) GetApiName added in v0.4.28

func (d *WatchServiceDescriptor) GetApiName() string

func (*WatchServiceDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchServiceDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchServiceDescriptor) GetFullMethodName() string

func (*WatchServiceDescriptor) GetMethodName added in v0.4.28

func (d *WatchServiceDescriptor) GetMethodName() string

func (*WatchServiceDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchServiceDescriptor) GetProtoPkgName() string

func (*WatchServiceDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchServiceDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchServiceDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchServiceDescriptor) GetServiceDomain() string

func (*WatchServiceDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchServiceDescriptor) GetServiceVersion() string

func (*WatchServiceDescriptor) GetVerb added in v0.4.28

func (d *WatchServiceDescriptor) GetVerb() string

func (*WatchServiceDescriptor) HasResource added in v0.4.30

func (d *WatchServiceDescriptor) HasResource() bool

func (*WatchServiceDescriptor) IsClientStream added in v0.4.28

func (d *WatchServiceDescriptor) IsClientStream() bool

func (*WatchServiceDescriptor) IsCollection added in v0.4.30

func (d *WatchServiceDescriptor) IsCollection() bool

func (*WatchServiceDescriptor) IsPlural added in v0.4.30

func (d *WatchServiceDescriptor) IsPlural() bool

func (*WatchServiceDescriptor) IsServerStream added in v0.4.28

func (d *WatchServiceDescriptor) IsServerStream() bool

func (*WatchServiceDescriptor) IsUnary added in v0.4.28

func (d *WatchServiceDescriptor) IsUnary() bool

func (*WatchServiceDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchServiceDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchServiceDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchServiceDescriptor) RequestHasResourceBody() bool

type WatchServiceDescriptorClientMsgHandle added in v0.4.28

type WatchServiceDescriptorClientMsgHandle struct{}

func (*WatchServiceDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchServiceDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchServiceDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchServiceDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchServiceDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchServiceDescriptorServerMsgHandle added in v0.4.28

type WatchServiceDescriptorServerMsgHandle struct{}

func (*WatchServiceDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchServiceDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchServiceDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchServiceDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchServiceDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchServiceRequest

type WatchServiceRequest struct {

	// Name of ntt.meta.v1alpha2.Service
	Name *service.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 *service.Service_FieldMask `` /* 139-byte string literal not displayed */
	// View defines list of standard response fields present in response items.
	// Additional fields can be amended by request field field_mask
	View view.View `protobuf:"varint,4,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// contains filtered or unexported fields
}

Request message for method [WatchService][ntt.meta.v1alpha2.WatchService]

func (*WatchServiceRequest) Descriptor

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

Deprecated, Use WatchServiceRequest.ProtoReflect.Descriptor instead.

func (*WatchServiceRequest) GetFieldMask

func (m *WatchServiceRequest) GetFieldMask() *service.Service_FieldMask

func (*WatchServiceRequest) GetName

func (m *WatchServiceRequest) GetName() *service.Name

func (*WatchServiceRequest) GetView

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

func (*WatchServiceRequest) GotenMessage

func (*WatchServiceRequest) GotenMessage()

func (*WatchServiceRequest) GotenValidate

func (obj *WatchServiceRequest) GotenValidate() error

func (*WatchServiceRequest) Marshal

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

func (*WatchServiceRequest) MarshalJSON

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

func (*WatchServiceRequest) ProtoMessage

func (*WatchServiceRequest) ProtoMessage()

func (*WatchServiceRequest) ProtoReflect

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

func (*WatchServiceRequest) Reset

func (m *WatchServiceRequest) Reset()

func (*WatchServiceRequest) SetFieldMask

func (m *WatchServiceRequest) SetFieldMask(fv *service.Service_FieldMask)

func (*WatchServiceRequest) SetName

func (m *WatchServiceRequest) SetName(fv *service.Name)

func (*WatchServiceRequest) SetView

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

func (*WatchServiceRequest) String

func (m *WatchServiceRequest) String() string

func (*WatchServiceRequest) Unmarshal

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

func (*WatchServiceRequest) UnmarshalJSON

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

type WatchServiceResponse

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

WatchServiceResponse

func (*WatchServiceResponse) Descriptor

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

Deprecated, Use WatchServiceResponse.ProtoReflect.Descriptor instead.

func (*WatchServiceResponse) GetChange

func (m *WatchServiceResponse) GetChange() *service.ServiceChange

func (*WatchServiceResponse) GotenMessage

func (*WatchServiceResponse) GotenMessage()

func (*WatchServiceResponse) GotenValidate

func (obj *WatchServiceResponse) GotenValidate() error

func (*WatchServiceResponse) Marshal

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

func (*WatchServiceResponse) MarshalJSON

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

func (*WatchServiceResponse) ProtoMessage

func (*WatchServiceResponse) ProtoMessage()

func (*WatchServiceResponse) ProtoReflect

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

func (*WatchServiceResponse) Reset

func (m *WatchServiceResponse) Reset()

func (*WatchServiceResponse) SetChange

func (m *WatchServiceResponse) SetChange(fv *service.ServiceChange)

func (*WatchServiceResponse) String

func (m *WatchServiceResponse) String() string

func (*WatchServiceResponse) Unmarshal

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

func (*WatchServiceResponse) UnmarshalJSON

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

type WatchServicesClientStream

type WatchServicesClientStream interface {
	Recv() (*WatchServicesResponse, error)
	grpc.ClientStream
}

type WatchServicesDescriptor added in v0.4.28

type WatchServicesDescriptor struct{}

func GetWatchServicesDescriptor added in v0.4.28

func GetWatchServicesDescriptor() *WatchServicesDescriptor

func (*WatchServicesDescriptor) GetApiDescriptor added in v0.4.28

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

func (*WatchServicesDescriptor) GetApiName added in v0.4.28

func (d *WatchServicesDescriptor) GetApiName() string

func (*WatchServicesDescriptor) GetClientMsgReflectHandle added in v0.4.28

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

func (*WatchServicesDescriptor) GetFullMethodName added in v0.4.28

func (d *WatchServicesDescriptor) GetFullMethodName() string

func (*WatchServicesDescriptor) GetMethodName added in v0.4.28

func (d *WatchServicesDescriptor) GetMethodName() string

func (*WatchServicesDescriptor) GetProtoPkgName added in v0.4.28

func (d *WatchServicesDescriptor) GetProtoPkgName() string

func (*WatchServicesDescriptor) GetResourceDescriptor added in v0.4.30

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

func (*WatchServicesDescriptor) GetServerMsgReflectHandle added in v0.4.28

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

func (*WatchServicesDescriptor) GetServiceDomain added in v0.4.28

func (d *WatchServicesDescriptor) GetServiceDomain() string

func (*WatchServicesDescriptor) GetServiceVersion added in v0.4.28

func (d *WatchServicesDescriptor) GetServiceVersion() string

func (*WatchServicesDescriptor) GetVerb added in v0.4.28

func (d *WatchServicesDescriptor) GetVerb() string

func (*WatchServicesDescriptor) HasResource added in v0.4.30

func (d *WatchServicesDescriptor) HasResource() bool

func (*WatchServicesDescriptor) IsClientStream added in v0.4.28

func (d *WatchServicesDescriptor) IsClientStream() bool

func (*WatchServicesDescriptor) IsCollection added in v0.4.30

func (d *WatchServicesDescriptor) IsCollection() bool

func (*WatchServicesDescriptor) IsPlural added in v0.4.30

func (d *WatchServicesDescriptor) IsPlural() bool

func (*WatchServicesDescriptor) IsServerStream added in v0.4.28

func (d *WatchServicesDescriptor) IsServerStream() bool

func (*WatchServicesDescriptor) IsUnary added in v0.4.28

func (d *WatchServicesDescriptor) IsUnary() bool

func (*WatchServicesDescriptor) NewEmptyClientMsg added in v0.4.28

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

func (*WatchServicesDescriptor) NewEmptyServerMsg added in v0.4.28

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

func (*WatchServicesDescriptor) RequestHasResourceBody added in v0.4.28

func (d *WatchServicesDescriptor) RequestHasResourceBody() bool

type WatchServicesDescriptorClientMsgHandle added in v0.4.28

type WatchServicesDescriptorClientMsgHandle struct{}

func (*WatchServicesDescriptorClientMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchServicesDescriptorClientMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchServicesDescriptorClientMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchServicesDescriptorClientMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchServicesDescriptorClientMsgHandle) ExtractResourceNames added in v0.4.30

type WatchServicesDescriptorServerMsgHandle added in v0.4.28

type WatchServicesDescriptorServerMsgHandle struct{}

func (*WatchServicesDescriptorServerMsgHandle) ExtractCollectionName added in v0.4.30

func (*WatchServicesDescriptorServerMsgHandle) ExtractResourceBodies added in v1.0.21

func (*WatchServicesDescriptorServerMsgHandle) ExtractResourceBody added in v1.0.21

func (*WatchServicesDescriptorServerMsgHandle) ExtractResourceName added in v0.4.30

func (*WatchServicesDescriptorServerMsgHandle) ExtractResourceNames added in v0.4.30

type WatchServicesRequest

type WatchServicesRequest 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"`
	// Requested page size. Server may return fewer Services 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 *service.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 *service.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 *service.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 Service that don't affect
	// any of masked fields won't be sent back.
	FieldMask *service.Service_FieldMask `` /* 139-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
	// Service that don't affect any of masked fields won't be sent back.
	View view.View `protobuf:"varint,8,opt,name=view,proto3,enum=goten.types.View" json:"view,omitempty" firestore:"view"`
	// Maximum amount of changes in each response message. Query result response
	// is divided on the server side into chunks with size of a specified amount
	// to limit memory footprint of each message. Responses will hold information
	// whether more elements will continue for the actual change. If unspecified,
	// server will pick an appropriate default.
	MaxChunkSize int32 `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Request message for method [WatchServices][ntt.meta.v1alpha2.WatchServices]

func (*WatchServicesRequest) Descriptor

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

Deprecated, Use WatchServicesRequest.ProtoReflect.Descriptor instead.

func (*WatchServicesRequest) GetFieldMask

func (m *WatchServicesRequest) GetFieldMask() *service.Service_FieldMask

func (*WatchServicesRequest) GetFilter

func (m *WatchServicesRequest) GetFilter() *service.Filter

func (*WatchServicesRequest) GetMaxChunkSize

func (m *WatchServicesRequest) GetMaxChunkSize() int32

func (*WatchServicesRequest) GetOrderBy

func (m *WatchServicesRequest) GetOrderBy() *service.OrderBy

func (*WatchServicesRequest) GetPageSize

func (m *WatchServicesRequest) GetPageSize() int32

func (*WatchServicesRequest) GetPageToken

func (m *WatchServicesRequest) GetPageToken() *service.PagerCursor

func (*WatchServicesRequest) GetResumeToken

func (m *WatchServicesRequest) GetResumeToken() string

func (*WatchServicesRequest) GetStartingTime added in v0.9.0

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

func (*WatchServicesRequest) GetType

func (*WatchServicesRequest) GetView

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

func (*WatchServicesRequest) GotenMessage

func (*WatchServicesRequest) GotenMessage()

func (*WatchServicesRequest) GotenValidate

func (obj *WatchServicesRequest) GotenValidate() error

func (*WatchServicesRequest) Marshal

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

func (*WatchServicesRequest) MarshalJSON

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

func (*WatchServicesRequest) ProtoMessage

func (*WatchServicesRequest) ProtoMessage()

func (*WatchServicesRequest) ProtoReflect

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

func (*WatchServicesRequest) Reset

func (m *WatchServicesRequest) Reset()

func (*WatchServicesRequest) SetFieldMask

func (m *WatchServicesRequest) SetFieldMask(fv *service.Service_FieldMask)

func (*WatchServicesRequest) SetFilter

func (m *WatchServicesRequest) SetFilter(fv *service.Filter)

func (*WatchServicesRequest) SetMaxChunkSize

func (m *WatchServicesRequest) SetMaxChunkSize(fv int32)

func (*WatchServicesRequest) SetOrderBy

func (m *WatchServicesRequest) SetOrderBy(fv *service.OrderBy)

func (*WatchServicesRequest) SetPageSize

func (m *WatchServicesRequest) SetPageSize(fv int32)

func (*WatchServicesRequest) SetPageToken

func (m *WatchServicesRequest) SetPageToken(fv *service.PagerCursor)

func (*WatchServicesRequest) SetResumeToken

func (m *WatchServicesRequest) SetResumeToken(fv string)

func (*WatchServicesRequest) SetStartingTime added in v0.9.0

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

func (*WatchServicesRequest) SetType

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

func (*WatchServicesRequest) SetView

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

func (*WatchServicesRequest) String

func (m *WatchServicesRequest) String() string

func (*WatchServicesRequest) Unmarshal

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

func (*WatchServicesRequest) UnmarshalJSON

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

type WatchServicesResponse

type WatchServicesResponse struct {

	// Changes of Services
	ServiceChanges []*service.ServiceChange `` /* 130-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 Services 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 *WatchServicesResponse_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 (Services 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
}

WatchServicesResponse

func (*WatchServicesResponse) Descriptor

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

Deprecated, Use WatchServicesResponse.ProtoReflect.Descriptor instead.

func (*WatchServicesResponse) GetIsCurrent

func (m *WatchServicesResponse) GetIsCurrent() bool

func (*WatchServicesResponse) GetIsHardReset

func (m *WatchServicesResponse) GetIsHardReset() bool

func (*WatchServicesResponse) GetIsSoftReset

func (m *WatchServicesResponse) GetIsSoftReset() bool

func (*WatchServicesResponse) GetPageTokenChange

func (*WatchServicesResponse) GetResumeToken

func (m *WatchServicesResponse) GetResumeToken() string

func (*WatchServicesResponse) GetServiceChanges

func (m *WatchServicesResponse) GetServiceChanges() []*service.ServiceChange

func (*WatchServicesResponse) GetSnapshotSize

func (m *WatchServicesResponse) GetSnapshotSize() int64

func (*WatchServicesResponse) GotenMessage

func (*WatchServicesResponse) GotenMessage()

func (*WatchServicesResponse) GotenValidate

func (obj *WatchServicesResponse) GotenValidate() error

func (*WatchServicesResponse) Marshal

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

func (*WatchServicesResponse) MarshalJSON

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

func (*WatchServicesResponse) ProtoMessage

func (*WatchServicesResponse) ProtoMessage()

func (*WatchServicesResponse) ProtoReflect

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

func (*WatchServicesResponse) Reset

func (m *WatchServicesResponse) Reset()

func (*WatchServicesResponse) SetIsCurrent

func (m *WatchServicesResponse) SetIsCurrent(fv bool)

func (*WatchServicesResponse) SetIsHardReset

func (m *WatchServicesResponse) SetIsHardReset(fv bool)

func (*WatchServicesResponse) SetIsSoftReset

func (m *WatchServicesResponse) SetIsSoftReset(fv bool)

func (*WatchServicesResponse) SetPageTokenChange

func (*WatchServicesResponse) SetResumeToken

func (m *WatchServicesResponse) SetResumeToken(fv string)

func (*WatchServicesResponse) SetServiceChanges

func (m *WatchServicesResponse) SetServiceChanges(fv []*service.ServiceChange)

func (*WatchServicesResponse) SetSnapshotSize

func (m *WatchServicesResponse) SetSnapshotSize(fv int64)

func (*WatchServicesResponse) String

func (m *WatchServicesResponse) String() string

func (*WatchServicesResponse) Unmarshal

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

func (*WatchServicesResponse) UnmarshalJSON

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

type WatchServicesResponse_PageTokenChange

type WatchServicesResponse_PageTokenChange struct {

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

func (*WatchServicesResponse_PageTokenChange) Descriptor

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

Deprecated, Use WatchServicesResponse_PageTokenChange.ProtoReflect.Descriptor instead.

func (*WatchServicesResponse_PageTokenChange) GetNextPageToken

func (*WatchServicesResponse_PageTokenChange) GetPrevPageToken

func (*WatchServicesResponse_PageTokenChange) GotenMessage

func (*WatchServicesResponse_PageTokenChange) GotenMessage()

func (*WatchServicesResponse_PageTokenChange) GotenValidate

func (obj *WatchServicesResponse_PageTokenChange) GotenValidate() error

func (*WatchServicesResponse_PageTokenChange) Marshal

func (*WatchServicesResponse_PageTokenChange) MarshalJSON

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

func (*WatchServicesResponse_PageTokenChange) ProtoMessage

func (*WatchServicesResponse_PageTokenChange) ProtoMessage()

func (*WatchServicesResponse_PageTokenChange) ProtoReflect

func (*WatchServicesResponse_PageTokenChange) Reset

func (*WatchServicesResponse_PageTokenChange) SetNextPageToken

func (*WatchServicesResponse_PageTokenChange) SetPrevPageToken

func (*WatchServicesResponse_PageTokenChange) String

func (*WatchServicesResponse_PageTokenChange) Unmarshal

func (*WatchServicesResponse_PageTokenChange) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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