Package cloud.google.com/go/apps/events/subscriptions/apiv1/subscriptionspb (v0.5.2)

var (
	Subscription_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "SUSPENDED",
		3: "DELETED",
	}
	Subscription_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"SUSPENDED":         2,
		"DELETED":           3,
	}
)

var (
	Subscription_ErrorType_name = map[int32]string{
		0: "ERROR_TYPE_UNSPECIFIED",
		1: "USER_SCOPE_REVOKED",
		2: "RESOURCE_DELETED",
		3: "USER_AUTHORIZATION_FAILURE",
		4: "ENDPOINT_PERMISSION_DENIED",
		6: "ENDPOINT_NOT_FOUND",
		7: "ENDPOINT_RESOURCE_EXHAUSTED",
		5: "OTHER",
	}
	Subscription_ErrorType_value = map[string]int32{
		"ERROR_TYPE_UNSPECIFIED":      0,
		"USER_SCOPE_REVOKED":          1,
		"RESOURCE_DELETED":            2,
		"USER_AUTHORIZATION_FAILURE":  3,
		"ENDPOINT_PERMISSION_DENIED":  4,
		"ENDPOINT_NOT_FOUND":          6,
		"ENDPOINT_RESOURCE_EXHAUSTED": 7,
		"OTHER":                       5,
	}
)

var File_google_apps_events_subscriptions_v1_subscription_resource_proto protoreflect.FileDescriptor

var File_google_apps_events_subscriptions_v1_subscriptions_service_proto protoreflect.FileDescriptor

func RegisterSubscriptionsServiceServer(s *grpc.Server, srv SubscriptionsServiceServer)

type CreateSubscriptionMetadata struct {
	// contains filtered or unexported fields
}

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

func (*CreateSubscriptionMetadata) ProtoMessage()

func (x *CreateSubscriptionMetadata) ProtoReflect() protoreflect.Message

func (x *CreateSubscriptionMetadata) Reset()

func (x *CreateSubscriptionMetadata) String() string

type CreateSubscriptionRequest struct {

	// Required. The subscription resource to create.
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Optional. If set to `true`, validates and previews the request, but doesn't
	// create the subscription.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *CreateSubscriptionRequest) GetSubscription() *Subscription

func (x *CreateSubscriptionRequest) GetValidateOnly() bool

func (*CreateSubscriptionRequest) ProtoMessage()

func (x *CreateSubscriptionRequest) ProtoReflect() protoreflect.Message

func (x *CreateSubscriptionRequest) Reset()

func (x *CreateSubscriptionRequest) String() string

type DeleteSubscriptionMetadata struct {
	// contains filtered or unexported fields
}

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

func (*DeleteSubscriptionMetadata) ProtoMessage()

func (x *DeleteSubscriptionMetadata) ProtoReflect() protoreflect.Message

func (x *DeleteSubscriptionMetadata) Reset()

func (x *DeleteSubscriptionMetadata) String() string

type DeleteSubscriptionRequest struct {

	// Required. Resource name of the subscription to delete.
	//
	// Format: `subscriptions/{subscription}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. If set to `true`, validates and previews the request, but doesn't
	// delete the subscription.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// Optional. If set to `true` and the subscription isn't found, the request
	// succeeds but doesn't delete the subscription.
	AllowMissing bool `protobuf:"varint,3,opt,name=allow_missing,json=allowMissing,proto3" json:"allow_missing,omitempty"`
	// Optional. Etag of the subscription.
	//
	// If present, it must match with the server's etag. Otherwise, request
	// fails with the status `ABORTED`.
	Etag string `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *DeleteSubscriptionRequest) GetAllowMissing() bool

func (x *DeleteSubscriptionRequest) GetEtag() string

func (x *DeleteSubscriptionRequest) GetName() string

func (x *DeleteSubscriptionRequest) GetValidateOnly() bool

func (*DeleteSubscriptionRequest) ProtoMessage()

func (x *DeleteSubscriptionRequest) ProtoReflect() protoreflect.Message

func (x *DeleteSubscriptionRequest) Reset()

func (x *DeleteSubscriptionRequest) String() string

type GetSubscriptionRequest struct {

	// Required. Resource name of the subscription.
	//
	// Format: `subscriptions/{subscription}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *GetSubscriptionRequest) GetName() string

func (*GetSubscriptionRequest) ProtoMessage()

func (x *GetSubscriptionRequest) ProtoReflect() protoreflect.Message

func (x *GetSubscriptionRequest) Reset()

func (x *GetSubscriptionRequest) String() string

type ListSubscriptionsRequest struct {

	// Optional. The maximum number of subscriptions to return. The service might
	// return fewer than this value.
	//
	// If unspecified or set to `0`, up to 50 subscriptions are returned.
	//
	// The maximum value is 100. If you specify a value more than 100, the system
	// only returns 100 subscriptions.
	PageSize int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Optional. A page token, received from a previous list subscriptions call.
	// Provide this parameter to retrieve the subsequent page.
	//
	// When paginating, the filter value should match the call that provided the
	// page token. Passing a different value might lead to unexpected results.
	PageToken string `protobuf:"bytes,2,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Required. A query filter.
	//
	// You can filter subscriptions by event type (`event_types`)
	// and target resource (`target_resource`).
	//
	// You must specify at least one event type in your query. To filter for
	// multiple event types, use the `OR` operator.
	//
	// To filter by both event type and target resource, use the `AND` operator
	// and specify the full resource name, such as
	// `//chat.googleapis.com/spaces/{space}`.
	//
	// For example, the following queries are valid:
	//
	// ```
	// event_types:"google.workspace.chat.membership.v1.updated" OR
	//
	//	event_types:"google.workspace.chat.message.v1.created"
	//
	// event_types:"google.workspace.chat.message.v1.created" AND
	//
	//	target_resource="//chat.googleapis.com/spaces/{space}"
	//
	// ( event_types:"google.workspace.chat.membership.v1.updated" OR
	//
	//	event_types:"google.workspace.chat.message.v1.created" ) AND
	//	target_resource="//chat.googleapis.com/spaces/{space}"
	//
	// ```
	//
	// The server rejects invalid queries with an `INVALID_ARGUMENT`
	// error.
	Filter string `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListSubscriptionsRequest) GetFilter() string

func (x *ListSubscriptionsRequest) GetPageSize() int32

func (x *ListSubscriptionsRequest) GetPageToken() string

func (*ListSubscriptionsRequest) ProtoMessage()

func (x *ListSubscriptionsRequest) ProtoReflect() protoreflect.Message

func (x *ListSubscriptionsRequest) Reset()

func (x *ListSubscriptionsRequest) String() string

type ListSubscriptionsResponse struct {

	// List of subscriptions.
	Subscriptions []*Subscription `protobuf:"bytes,1,rep,name=subscriptions,proto3" json:"subscriptions,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ListSubscriptionsResponse) GetNextPageToken() string

func (x *ListSubscriptionsResponse) GetSubscriptions() []*Subscription

func (*ListSubscriptionsResponse) ProtoMessage()

func (x *ListSubscriptionsResponse) ProtoReflect() protoreflect.Message

func (x *ListSubscriptionsResponse) Reset()

func (x *ListSubscriptionsResponse) String() string

type NotificationEndpoint struct {

	// Types that are assignable to Endpoint:
	//
	//	*NotificationEndpoint_PubsubTopic
	Endpoint isNotificationEndpoint_Endpoint `protobuf_oneof:"endpoint"`
	// contains filtered or unexported fields
}

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

func (m *NotificationEndpoint) GetEndpoint() isNotificationEndpoint_Endpoint

func (x *NotificationEndpoint) GetPubsubTopic() string

func (*NotificationEndpoint) ProtoMessage()

func (x *NotificationEndpoint) ProtoReflect() protoreflect.Message

func (x *NotificationEndpoint) Reset()

func (x *NotificationEndpoint) String() string

type NotificationEndpoint_PubsubTopic struct {
	// Immutable. The Cloud Pub/Sub topic that receives events for the
	// subscription.
	//
	// Format: `projects/{project}/topics/{topic}`
	//
	// You must create the topic in the same Google Cloud project where
	// you create this subscription.
	//
	// When the topic receives events, the events are encoded as Cloud Pub/Sub
	// messages. For details, see the [Google Cloud Pub/Sub Protocol Binding for
	// CloudEvents](https://github.com/googleapis/google-cloudevents/blob/main/docs/spec/pubsub.md).
	PubsubTopic string `protobuf:"bytes,1,opt,name=pubsub_topic,json=pubsubTopic,proto3,oneof"`
}

type PayloadOptions struct {

	// Optional. Whether the event payload includes data about the resource that
	// changed. For example, for an event where a Google Chat message was created,
	// whether the payload contains data about the
	// [`Message`](https://developers.google.com/chat/api/reference/rest/v1/spaces.messages)
	// resource. If false, the event payload only includes the name of the changed
	// resource.
	IncludeResource bool `protobuf:"varint,1,opt,name=include_resource,json=includeResource,proto3" json:"include_resource,omitempty"`
	// Optional. If `include_resource` is set to `true`, the list of fields to
	// include in the event payload. Separate fields with a comma. For example, to
	// include a Google Chat message's sender and create time, enter
	// `message.sender,message.createTime`. If omitted, the payload includes all
	// fields for the resource.
	//
	// If you specify a field that doesn't exist for the resource, the system
	// ignores the field.
	FieldMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=field_mask,json=fieldMask,proto3" json:"field_mask,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *PayloadOptions) GetFieldMask() *fieldmaskpb.FieldMask

func (x *PayloadOptions) GetIncludeResource() bool

func (*PayloadOptions) ProtoMessage()

func (x *PayloadOptions) ProtoReflect() protoreflect.Message

func (x *PayloadOptions) Reset()

func (x *PayloadOptions) String() string

type ReactivateSubscriptionMetadata struct {
	// contains filtered or unexported fields
}

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

func (*ReactivateSubscriptionMetadata) ProtoMessage()

func (x *ReactivateSubscriptionMetadata) ProtoReflect() protoreflect.Message

func (x *ReactivateSubscriptionMetadata) Reset()

func (x *ReactivateSubscriptionMetadata) String() string

type ReactivateSubscriptionRequest struct {

	// Required. Resource name of the subscription.
	//
	// Format: `subscriptions/{subscription}`
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *ReactivateSubscriptionRequest) GetName() string

func (*ReactivateSubscriptionRequest) ProtoMessage()

func (x *ReactivateSubscriptionRequest) ProtoReflect() protoreflect.Message

func (x *ReactivateSubscriptionRequest) Reset()

func (x *ReactivateSubscriptionRequest) String() string

type Subscription struct {
	Expiration isSubscription_Expiration `protobuf_oneof:"expiration"`

	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	TargetResource string `protobuf:"bytes,4,opt,name=target_resource,json=targetResource,proto3" json:"target_resource,omitempty"`

	EventTypes []string `protobuf:"bytes,5,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`

	PayloadOptions *PayloadOptions `protobuf:"bytes,6,opt,name=payload_options,json=payloadOptions,proto3" json:"payload_options,omitempty"`

	NotificationEndpoint *NotificationEndpoint `protobuf:"bytes,7,opt,name=notification_endpoint,json=notificationEndpoint,proto3" json:"notification_endpoint,omitempty"`

	State Subscription_State `protobuf:"varint,8,opt,name=state,proto3,enum=google.apps.events.subscriptions.v1.Subscription_State" json:"state,omitempty"`

	SuspensionReason Subscription_ErrorType "" /* 175 byte string literal not displayed */

	Authority string `protobuf:"bytes,10,opt,name=authority,proto3" json:"authority,omitempty"`

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	Reconciling bool `protobuf:"varint,15,opt,name=reconciling,proto3" json:"reconciling,omitempty"`

	Etag string `protobuf:"bytes,17,opt,name=etag,proto3" json:"etag,omitempty"`

}

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

func (x *Subscription) GetAuthority() string

func (x *Subscription) GetCreateTime() *timestamppb.Timestamp

func (x *Subscription) GetEtag() string

func (x *Subscription) GetEventTypes() []string

func (m *Subscription) GetExpiration() isSubscription_Expiration

func (x *Subscription) GetExpireTime() *timestamppb.Timestamp

func (x *Subscription) GetName() string

func (x *Subscription) GetNotificationEndpoint() *NotificationEndpoint

func (x *Subscription) GetPayloadOptions() *PayloadOptions

func (x *Subscription) GetReconciling() bool

func (x *Subscription) GetState() Subscription_State

func (x *Subscription) GetSuspensionReason() Subscription_ErrorType

func (x *Subscription) GetTargetResource() string

func (x *Subscription) GetTtl() *durationpb.Duration

func (x *Subscription) GetUid() string

func (x *Subscription) GetUpdateTime() *timestamppb.Timestamp

func (*Subscription) ProtoMessage()

func (x *Subscription) ProtoReflect() protoreflect.Message

func (x *Subscription) Reset()

func (x *Subscription) String() string

type Subscription_ErrorType int32

const (
	// Default value. This value is unused.
	Subscription_ERROR_TYPE_UNSPECIFIED Subscription_ErrorType = 0
	// The authorizing user has revoked the grant of one or more OAuth scopes.
	// To learn more about authorization for Google Workspace, see [Configure
	// the OAuth consent
	// screen](https://developers.google.com/workspace/guides/configure-oauth-consent#choose-scopes).
	Subscription_USER_SCOPE_REVOKED Subscription_ErrorType = 1
	// The target resource for the subscription no longer exists.
	Subscription_RESOURCE_DELETED Subscription_ErrorType = 2
	// The user that authorized the creation of the subscription no longer has
	// access to the subscription's target resource.
	Subscription_USER_AUTHORIZATION_FAILURE Subscription_ErrorType = 3
	// The Google Workspace application doesn't have access to deliver
	// events to your subscription's notification endpoint.
	Subscription_ENDPOINT_PERMISSION_DENIED Subscription_ErrorType = 4
	// The subscription's notification endpoint doesn't exist, or the endpoint
	// can't be found in the Google Cloud project where you created the
	// subscription.
	Subscription_ENDPOINT_NOT_FOUND Subscription_ErrorType = 6
	// The subscription's notification endpoint failed to receive events due to
	// insufficient quota or reaching rate limiting.
	Subscription_ENDPOINT_RESOURCE_EXHAUSTED Subscription_ErrorType = 7
	// An unidentified error has occurred.
	Subscription_OTHER Subscription_ErrorType = 5
)

func (Subscription_ErrorType) Descriptor() protoreflect.EnumDescriptor

func (x Subscription_ErrorType) Enum() *Subscription_ErrorType

func (Subscription_ErrorType) EnumDescriptor() ([]byte, []int)

func (x Subscription_ErrorType) Number() protoreflect.EnumNumber

func (x Subscription_ErrorType) String() string

func (Subscription_ErrorType) Type() protoreflect.EnumType

type Subscription_ExpireTime struct {
	// Non-empty default. The timestamp in UTC when the subscription expires.
	// Always displayed on output, regardless of what was used on input.
	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=expire_time,json=expireTime,proto3,oneof"`
}

type Subscription_State int32

const (
	// Default value. This value is unused.
	Subscription_STATE_UNSPECIFIED Subscription_State = 0
	// The subscription is active and can receive and deliver events to its
	// notification endpoint.
	Subscription_ACTIVE Subscription_State = 1
	// The subscription is unable to receive events due to an error.
	// To identify the error, see the
	// [`suspension_reason`][google.apps.events.subscriptions.v1.Subscription.suspension_reason]
	// field.
	Subscription_SUSPENDED Subscription_State = 2
	// The subscription is deleted.
	Subscription_DELETED Subscription_State = 3
)

func (Subscription_State) Descriptor() protoreflect.EnumDescriptor

func (x Subscription_State) Enum() *Subscription_State

func (Subscription_State) EnumDescriptor() ([]byte, []int)

func (x Subscription_State) Number() protoreflect.EnumNumber

func (x Subscription_State) String() string

func (Subscription_State) Type() protoreflect.EnumType

type Subscription_Ttl struct {
	// Input only. The time-to-live (TTL) or duration for the subscription. If
	// unspecified or set to `0`, uses the maximum possible duration.
	Ttl *durationpb.Duration `protobuf:"bytes,14,opt,name=ttl,proto3,oneof"`
}

type SubscriptionsServiceClient interface {
	// Creates a Google Workspace subscription. To learn how to use this
	// method, see [Create a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/create-subscription).
	CreateSubscription(ctx context.Context, in *CreateSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a Google Workspace subscription.
	// To learn how to use this method, see [Delete a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/delete-subscription).
	DeleteSubscription(ctx context.Context, in *DeleteSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Gets details about a Google Workspace subscription. To learn how to use
	// this method, see [Get details about a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/get-subscription).
	GetSubscription(ctx context.Context, in *GetSubscriptionRequest, opts ...grpc.CallOption) (*Subscription, error)
	// Lists Google Workspace subscriptions. To learn how to use this method, see
	// [List Google Workspace
	// subscriptions](https://developers.google.com/workspace/events/guides/list-subscriptions).
	ListSubscriptions(ctx context.Context, in *ListSubscriptionsRequest, opts ...grpc.CallOption) (*ListSubscriptionsResponse, error)
	// Updates or renews a Google Workspace subscription. To learn how to use this
	// method, see [Update or renew a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/update-subscription).
	UpdateSubscription(ctx context.Context, in *UpdateSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Reactivates a suspended Google Workspace subscription.
	//
	// This method resets your subscription's `State` field to `ACTIVE`. Before
	// you use this method, you must fix the error that suspended the
	// subscription. To learn how to use this method, see [Reactivate a Google
	// Workspace
	// subscription](https://developers.google.com/workspace/events/guides/reactivate-subscription).
	ReactivateSubscription(ctx context.Context, in *ReactivateSubscriptionRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}

func NewSubscriptionsServiceClient(cc grpc.ClientConnInterface) SubscriptionsServiceClient

type SubscriptionsServiceServer interface {
	// Creates a Google Workspace subscription. To learn how to use this
	// method, see [Create a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/create-subscription).
	CreateSubscription(context.Context, *CreateSubscriptionRequest) (*longrunningpb.Operation, error)
	// Deletes a Google Workspace subscription.
	// To learn how to use this method, see [Delete a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/delete-subscription).
	DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)
	// Gets details about a Google Workspace subscription. To learn how to use
	// this method, see [Get details about a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/get-subscription).
	GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)
	// Lists Google Workspace subscriptions. To learn how to use this method, see
	// [List Google Workspace
	// subscriptions](https://developers.google.com/workspace/events/guides/list-subscriptions).
	ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)
	// Updates or renews a Google Workspace subscription. To learn how to use this
	// method, see [Update or renew a Google Workspace
	// subscription](https://developers.google.com/workspace/events/guides/update-subscription).
	UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*longrunningpb.Operation, error)
	// Reactivates a suspended Google Workspace subscription.
	//
	// This method resets your subscription's `State` field to `ACTIVE`. Before
	// you use this method, you must fix the error that suspended the
	// subscription. To learn how to use this method, see [Reactivate a Google
	// Workspace
	// subscription](https://developers.google.com/workspace/events/guides/reactivate-subscription).
	ReactivateSubscription(context.Context, *ReactivateSubscriptionRequest) (*longrunningpb.Operation, error)
}

type UnimplementedSubscriptionsServiceServer struct {
}

func (*UnimplementedSubscriptionsServiceServer) CreateSubscription(context.Context, *CreateSubscriptionRequest) (*longrunningpb.Operation, error)

func (*UnimplementedSubscriptionsServiceServer) DeleteSubscription(context.Context, *DeleteSubscriptionRequest) (*longrunningpb.Operation, error)

func (*UnimplementedSubscriptionsServiceServer) GetSubscription(context.Context, *GetSubscriptionRequest) (*Subscription, error)

func (*UnimplementedSubscriptionsServiceServer) ListSubscriptions(context.Context, *ListSubscriptionsRequest) (*ListSubscriptionsResponse, error)

func (*UnimplementedSubscriptionsServiceServer) ReactivateSubscription(context.Context, *ReactivateSubscriptionRequest) (*longrunningpb.Operation, error)

func (*UnimplementedSubscriptionsServiceServer) UpdateSubscription(context.Context, *UpdateSubscriptionRequest) (*longrunningpb.Operation, error)

type UpdateSubscriptionMetadata struct {
	// contains filtered or unexported fields
}

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

func (*UpdateSubscriptionMetadata) ProtoMessage()

func (x *UpdateSubscriptionMetadata) ProtoReflect() protoreflect.Message

func (x *UpdateSubscriptionMetadata) Reset()

func (x *UpdateSubscriptionMetadata) String() string

type UpdateSubscriptionRequest struct {

	// Required. The subscription to update.
	//
	// The subscription's `name` field is used to identify the subscription to
	// update.
	Subscription *Subscription `protobuf:"bytes,1,opt,name=subscription,proto3" json:"subscription,omitempty"`
	// Optional. Required. The field to update.
	//
	// You can update one of the following fields in a subscription:
	//
	//   - [`expire_time`][google.apps.events.subscriptions.v1.Subscription.expire_time]: The timestamp when the
	//     subscription expires.
	//   - [`ttl`][google.apps.events.subscriptions.v1.Subscription.ttl]: The
	//
	// time-to-live (TTL) or duration of the
	//
	//	subscription.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// Optional. If set to `true`, validates and previews the request, but doesn't
	// update the subscription.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *UpdateSubscriptionRequest) GetSubscription() *Subscription

func (x *UpdateSubscriptionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (x *UpdateSubscriptionRequest) GetValidateOnly() bool

func (*UpdateSubscriptionRequest) ProtoMessage()

func (x *UpdateSubscriptionRequest) ProtoReflect() protoreflect.Message

func (x *UpdateSubscriptionRequest) Reset()

func (x *UpdateSubscriptionRequest) String() string