resource_change_log_client

package
v1.5.7 Latest Latest
Warning

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

Go to latest
Published: Sep 26, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreatePreCommittedResourceChangeLogsDescriptor

type CreatePreCommittedResourceChangeLogsDescriptor struct{}

func GetCreatePreCommittedResourceChangeLogsDescriptor

func GetCreatePreCommittedResourceChangeLogsDescriptor() *CreatePreCommittedResourceChangeLogsDescriptor

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetApiDescriptor

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetApiName

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetClientMsgReflectHandle

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetFullMethodName

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetMethodName

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetProtoPkgName

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetResourceDescriptor

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetServerMsgReflectHandle

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetServiceDomain

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetServiceVersion

func (*CreatePreCommittedResourceChangeLogsDescriptor) GetVerb

func (*CreatePreCommittedResourceChangeLogsDescriptor) HasResource

func (*CreatePreCommittedResourceChangeLogsDescriptor) IsClientStream

func (*CreatePreCommittedResourceChangeLogsDescriptor) IsCollection

func (*CreatePreCommittedResourceChangeLogsDescriptor) IsPlural

func (*CreatePreCommittedResourceChangeLogsDescriptor) IsServerStream

func (*CreatePreCommittedResourceChangeLogsDescriptor) IsUnary

func (*CreatePreCommittedResourceChangeLogsDescriptor) NewEmptyClientMsg

func (*CreatePreCommittedResourceChangeLogsDescriptor) NewEmptyServerMsg

func (*CreatePreCommittedResourceChangeLogsDescriptor) RequestHasResourceBody

func (d *CreatePreCommittedResourceChangeLogsDescriptor) RequestHasResourceBody() bool

type CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle

type CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle struct{}

func (*CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle) ExtractCollectionName

func (*CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceBodies

func (*CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceBody

func (*CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceName

func (*CreatePreCommittedResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceNames

type CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle

type CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle struct{}

func (*CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle) ExtractCollectionName

func (*CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceBodies

func (*CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceBody

func (*CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceName

func (*CreatePreCommittedResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceNames

type CreatePreCommittedResourceChangeLogsRequest

type CreatePreCommittedResourceChangeLogsRequest struct {

	// ID of the request - must be same as the one used in activity logs
	RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty" firestore:"requestId"`
	// Time of the request
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty" firestore:"timestamp"`
	// Authentication data - informs who made a change
	Authentication *common.Authentication `protobuf:"bytes,3,opt,name=authentication,proto3" json:"authentication,omitempty" firestore:"authentication"`
	// Information about the service
	Service *common.ServiceData `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// Information about transaction
	Transaction *resource_change_log.ResourceChangeLog_TransactionInfo `protobuf:"bytes,5,opt,name=transaction,proto3" json:"transaction,omitempty" firestore:"transaction"`
	// List of changes
	Changes []*resource_change_log.ResourceChangeLog_ResourceChange `protobuf:"bytes,6,rep,name=changes,proto3" json:"changes,omitempty" firestore:"changes"`
	// contains filtered or unexported fields
}

A request message of the [CreatePreCommittedResourceChangeLogs](#createprecommittedresourcechangelogs-method) method.

func (*CreatePreCommittedResourceChangeLogsRequest) Descriptor

Deprecated, Use CreatePreCommittedResourceChangeLogsRequest.ProtoReflect.Descriptor instead.

func (*CreatePreCommittedResourceChangeLogsRequest) GetAuthentication

func (*CreatePreCommittedResourceChangeLogsRequest) GetChanges

func (*CreatePreCommittedResourceChangeLogsRequest) GetRequestId

func (*CreatePreCommittedResourceChangeLogsRequest) GetService

func (*CreatePreCommittedResourceChangeLogsRequest) GetTimestamp

func (*CreatePreCommittedResourceChangeLogsRequest) GetTransaction

func (*CreatePreCommittedResourceChangeLogsRequest) GotenMessage

func (*CreatePreCommittedResourceChangeLogsRequest) GotenValidate

func (*CreatePreCommittedResourceChangeLogsRequest) Marshal

func (*CreatePreCommittedResourceChangeLogsRequest) MarshalJSON

func (*CreatePreCommittedResourceChangeLogsRequest) ProtoMessage

func (*CreatePreCommittedResourceChangeLogsRequest) ProtoReflect

func (*CreatePreCommittedResourceChangeLogsRequest) Reset

func (*CreatePreCommittedResourceChangeLogsRequest) SetAuthentication

func (*CreatePreCommittedResourceChangeLogsRequest) SetChanges

func (*CreatePreCommittedResourceChangeLogsRequest) SetRequestId

func (*CreatePreCommittedResourceChangeLogsRequest) SetService

func (*CreatePreCommittedResourceChangeLogsRequest) SetTimestamp

func (*CreatePreCommittedResourceChangeLogsRequest) SetTransaction

func (*CreatePreCommittedResourceChangeLogsRequest) String

func (*CreatePreCommittedResourceChangeLogsRequest) Unmarshal

func (*CreatePreCommittedResourceChangeLogsRequest) UnmarshalJSON

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

type CreatePreCommittedResourceChangeLogsResponse

type CreatePreCommittedResourceChangeLogsResponse struct {

	// Resource change log keys - one key per each resource change, in same order
	LogKeys [][]byte `protobuf:"bytes,1,rep,name=log_keys,json=logKeys,proto3" json:"log_keys,omitempty" firestore:"logKeys"`
	// contains filtered or unexported fields
}

A response message of the [CreatePreCommittedResourceChangeLogs](#createprecommittedresourcechangelogs-method) method.

func (*CreatePreCommittedResourceChangeLogsResponse) Descriptor

Deprecated, Use CreatePreCommittedResourceChangeLogsResponse.ProtoReflect.Descriptor instead.

func (*CreatePreCommittedResourceChangeLogsResponse) GetLogKeys

func (*CreatePreCommittedResourceChangeLogsResponse) GotenMessage

func (*CreatePreCommittedResourceChangeLogsResponse) GotenValidate

func (*CreatePreCommittedResourceChangeLogsResponse) Marshal

func (*CreatePreCommittedResourceChangeLogsResponse) MarshalJSON

func (*CreatePreCommittedResourceChangeLogsResponse) ProtoMessage

func (*CreatePreCommittedResourceChangeLogsResponse) ProtoReflect

func (*CreatePreCommittedResourceChangeLogsResponse) Reset

func (*CreatePreCommittedResourceChangeLogsResponse) SetLogKeys

func (m *CreatePreCommittedResourceChangeLogsResponse) SetLogKeys(fv [][]byte)

func (*CreatePreCommittedResourceChangeLogsResponse) String

func (*CreatePreCommittedResourceChangeLogsResponse) Unmarshal

func (*CreatePreCommittedResourceChangeLogsResponse) UnmarshalJSON

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

type ListResourceChangeLogsDescriptor

type ListResourceChangeLogsDescriptor struct{}

func GetListResourceChangeLogsDescriptor

func GetListResourceChangeLogsDescriptor() *ListResourceChangeLogsDescriptor

func (*ListResourceChangeLogsDescriptor) GetApiDescriptor

func (*ListResourceChangeLogsDescriptor) GetApiName

func (d *ListResourceChangeLogsDescriptor) GetApiName() string

func (*ListResourceChangeLogsDescriptor) GetClientMsgReflectHandle

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

func (*ListResourceChangeLogsDescriptor) GetFullMethodName

func (d *ListResourceChangeLogsDescriptor) GetFullMethodName() string

func (*ListResourceChangeLogsDescriptor) GetMethodName

func (d *ListResourceChangeLogsDescriptor) GetMethodName() string

func (*ListResourceChangeLogsDescriptor) GetProtoPkgName

func (d *ListResourceChangeLogsDescriptor) GetProtoPkgName() string

func (*ListResourceChangeLogsDescriptor) GetResourceDescriptor

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

func (*ListResourceChangeLogsDescriptor) GetServerMsgReflectHandle

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

func (*ListResourceChangeLogsDescriptor) GetServiceDomain

func (d *ListResourceChangeLogsDescriptor) GetServiceDomain() string

func (*ListResourceChangeLogsDescriptor) GetServiceVersion

func (d *ListResourceChangeLogsDescriptor) GetServiceVersion() string

func (*ListResourceChangeLogsDescriptor) GetVerb

func (*ListResourceChangeLogsDescriptor) HasResource

func (d *ListResourceChangeLogsDescriptor) HasResource() bool

func (*ListResourceChangeLogsDescriptor) IsClientStream

func (d *ListResourceChangeLogsDescriptor) IsClientStream() bool

func (*ListResourceChangeLogsDescriptor) IsCollection

func (d *ListResourceChangeLogsDescriptor) IsCollection() bool

func (*ListResourceChangeLogsDescriptor) IsPlural

func (d *ListResourceChangeLogsDescriptor) IsPlural() bool

func (*ListResourceChangeLogsDescriptor) IsServerStream

func (d *ListResourceChangeLogsDescriptor) IsServerStream() bool

func (*ListResourceChangeLogsDescriptor) IsUnary

func (*ListResourceChangeLogsDescriptor) NewEmptyClientMsg

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

func (*ListResourceChangeLogsDescriptor) NewEmptyServerMsg

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

func (*ListResourceChangeLogsDescriptor) RequestHasResourceBody

func (d *ListResourceChangeLogsDescriptor) RequestHasResourceBody() bool

type ListResourceChangeLogsDescriptorClientMsgHandle

type ListResourceChangeLogsDescriptorClientMsgHandle struct{}

func (*ListResourceChangeLogsDescriptorClientMsgHandle) ExtractCollectionName

func (*ListResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceBodies

func (*ListResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceBody

func (*ListResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceName

func (*ListResourceChangeLogsDescriptorClientMsgHandle) ExtractResourceNames

type ListResourceChangeLogsDescriptorServerMsgHandle

type ListResourceChangeLogsDescriptorServerMsgHandle struct{}

func (*ListResourceChangeLogsDescriptorServerMsgHandle) ExtractCollectionName

func (*ListResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceBodies

func (*ListResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceBody

func (*ListResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceName

func (*ListResourceChangeLogsDescriptorServerMsgHandle) ExtractResourceNames

type ListResourceChangeLogsRequest

type ListResourceChangeLogsRequest struct {

	// Parent names of ntt.audit.v1.ResourceChangeLog
	Parents []*resource_change_log.ParentName `protobuf:"bytes,1,rep,customtype=ParentName,name=parents,proto3" json:"parents,omitempty" firestore:"parents"`
	// A audit filter that specifies which resource change logs should be returned
	Filter *resource_change_log.Filter `protobuf:"bytes,2,opt,customtype=Filter,name=filter,proto3" json:"filter,omitempty" firestore:"filter"`
	// The time interval for which results should be returned. Only logs
	// that contain data points in the specified interval are included
	// in the response.
	Interval *common.TimeInterval `protobuf:"bytes,4,opt,name=interval,proto3" json:"interval,omitempty" firestore:"interval"`
	// Cap on a number of resource change logs to be included in a response.
	// Number of logs in an actual response can be higher, since logs are
	// read in bulk with second precision - exceed logs above the limit will share
	// same timestamp as the logs below the limit.
	//
	// Results will be adjusted to the "end time" taken from interval field
	// (adjusted also by page_token if provided).
	PageSize int32 `protobuf:"varint,5,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty" firestore:"pageSize"`
	// Token which identifies next page with further results. Token should be
	// taken from ListResourceChangeLogsResponse
	// [ListResourceChangeLogsResponse.next_page_token][ntt.audit.v1.ListResourceChangeLogsResponse.next_page_token].
	PageToken string `protobuf:"bytes,6,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty" firestore:"pageToken"`
	// contains filtered or unexported fields
}

A request message of the [ListResourceChangeLogs](#listresourcechangelogs-method) method.

It returns resource changes for specified time range, region, scope and filter. Note that resource change logs are Resource oriented, primary object is resource here. Audit monitors resources that have non-custom store.

Note that filter field is mandatory and minimal filters are:

  • --filter 'service.name=[SERVICE_NAME] and resource.type=[RESOURCE_NAME]' (what is happening for this resource type)
  • --filter 'request_id=[REQUEST_ID]' (which resources were changed by this request_id?)

Be aware that server will append scope filter condition (and scope IN ...) to an any of the above filters. All scopes are extracted from parents field in ListResourceChangeLogsRequest body. This ensures that users can view only scopes he/she is allowed to.

For all of the above filters you can replace filter condition compare (=) with IN operator. You can therefore query for multiple services, methods or users at once. Above filters are also preferred as we have optimization for them.

Resource change logs can also be filtered by custom labels (field labels in ResourceChangeLog - pre and post versions). Labels are custom per each API resource - so you must specify service.name and resource.type conditions to enable them. For example, suppose you have a VM resource which contains "group" field, which is a reference to some other resource. If you create label "group" in VM resource spec (in proto model) you can make a following query:

```

--filter 'service.name=vms.domain.com and \
          resource.type=VM and \
          resource.post.labels.group=projects/P/vmgroups/myGroup'

```

Examples of usage (with cuttle, we are interested only in one region and scope):

* Checks activities within one hour for role binding resources

```bash
cuttle audit query activity-log --parents 'projects/demo' \
  --filter 'service.name="iam.edgelq.com" and \
            resource.type="RoleBinding"' \
  --interval '{"startTime":"2020-09-08T12:00:00Z",
  "endTime":"2020-09-08T13:00:00Z"}' \ -o json
```

* Checks modification of specific RoleBinding

```bash
cuttle audit query activity-log --parents 'projects/demo' \
  --filter 'service.name="iam.edgelq.com" and \
            resource.type="RoleBinding" and \
            resource.name="projects/x/roleBindings/myRB"' \
  --interval '{"startTime":"2020-09-08T12:00:00Z"}' \
  -o json
```
  • Checks changes on resource RoleBinding made by specific user (we need their email)

    ```bash cuttle audit query resource-change-log --parents 'projects/demo' \ --filter 'service.name="iam.edgelq.com" and \ resource.type="RoleBinding" and \ authentication.principal="user:we.know.who@domain.com"' \ --interval '{"startTime":"2020-09-08T12:00:00Z"}' \ -o json ```

func (*ListResourceChangeLogsRequest) Descriptor

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

Deprecated, Use ListResourceChangeLogsRequest.ProtoReflect.Descriptor instead.

func (*ListResourceChangeLogsRequest) GetFilter

func (*ListResourceChangeLogsRequest) GetInterval

func (*ListResourceChangeLogsRequest) GetPageSize

func (m *ListResourceChangeLogsRequest) GetPageSize() int32

func (*ListResourceChangeLogsRequest) GetPageToken

func (m *ListResourceChangeLogsRequest) GetPageToken() string

func (*ListResourceChangeLogsRequest) GetParents

func (*ListResourceChangeLogsRequest) GotenMessage

func (*ListResourceChangeLogsRequest) GotenMessage()

func (*ListResourceChangeLogsRequest) GotenValidate

func (obj *ListResourceChangeLogsRequest) GotenValidate() error

func (*ListResourceChangeLogsRequest) Marshal

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

func (*ListResourceChangeLogsRequest) MarshalJSON

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

func (*ListResourceChangeLogsRequest) ProtoMessage

func (*ListResourceChangeLogsRequest) ProtoMessage()

func (*ListResourceChangeLogsRequest) ProtoReflect

func (*ListResourceChangeLogsRequest) Reset

func (m *ListResourceChangeLogsRequest) Reset()

func (*ListResourceChangeLogsRequest) SetFilter

func (*ListResourceChangeLogsRequest) SetInterval

func (*ListResourceChangeLogsRequest) SetPageSize

func (m *ListResourceChangeLogsRequest) SetPageSize(fv int32)

func (*ListResourceChangeLogsRequest) SetPageToken

func (m *ListResourceChangeLogsRequest) SetPageToken(fv string)

func (*ListResourceChangeLogsRequest) SetParents

func (*ListResourceChangeLogsRequest) String

func (*ListResourceChangeLogsRequest) Unmarshal

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

func (*ListResourceChangeLogsRequest) UnmarshalJSON

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

type ListResourceChangeLogsResponse

type ListResourceChangeLogsResponse struct {

	// One or more resource change logs that match the filter included in the
	// request. Contains results from all queried regions. Its possible however
	// that some logs may be missing, for this see execution_errors.
	ResourceChangeLogs []*resource_change_log.ResourceChangeLog `` /* 148-byte string literal not displayed */
	// If there are more results than have been returned, then this field is set
	// to a non-empty value. To see the additional results,
	// use that value as `pageToken` in the next call to this method.
	NextPageToken string `` /* 128-byte string literal not displayed */
	// Query execution errors that may have caused the response data returned to
	// be incomplete. Because logs are stored only locally (for each region), all
	// resource change log queries are split and merged by a receiving request
	// server according to the queried regions. Its possible that some regions
	// will fail when request is redirected to them, but others not. For each
	// failed region, one execution error will be appended. In each ntt.rpc.Status
	// message, fields code and message will contain error obtained from failed
	// regional server, while field details will contain always one item and this
	// item will be of type ErrorDetails.
	ExecutionErrors []*rpc.Status `` /* 134-byte string literal not displayed */
	// contains filtered or unexported fields
}

A response message of the [ListResourceChangeLogs](#listresourcechangelogs-method) method.

Creates resource change log.

This request should not be used by regular users - only API services should be able to submit resource change logs. Developers of services should use logs exporter package offered along other Audit service packages instead of developing own components.

func (*ListResourceChangeLogsResponse) Descriptor

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

Deprecated, Use ListResourceChangeLogsResponse.ProtoReflect.Descriptor instead.

func (*ListResourceChangeLogsResponse) GetExecutionErrors

func (m *ListResourceChangeLogsResponse) GetExecutionErrors() []*rpc.Status

func (*ListResourceChangeLogsResponse) GetNextPageToken

func (m *ListResourceChangeLogsResponse) GetNextPageToken() string

func (*ListResourceChangeLogsResponse) GetResourceChangeLogs

func (*ListResourceChangeLogsResponse) GotenMessage

func (*ListResourceChangeLogsResponse) GotenMessage()

func (*ListResourceChangeLogsResponse) GotenValidate

func (obj *ListResourceChangeLogsResponse) GotenValidate() error

func (*ListResourceChangeLogsResponse) Marshal

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

func (*ListResourceChangeLogsResponse) MarshalJSON

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

func (*ListResourceChangeLogsResponse) ProtoMessage

func (*ListResourceChangeLogsResponse) ProtoMessage()

func (*ListResourceChangeLogsResponse) ProtoReflect

func (*ListResourceChangeLogsResponse) Reset

func (m *ListResourceChangeLogsResponse) Reset()

func (*ListResourceChangeLogsResponse) SetExecutionErrors

func (m *ListResourceChangeLogsResponse) SetExecutionErrors(fv []*rpc.Status)

func (*ListResourceChangeLogsResponse) SetNextPageToken

func (m *ListResourceChangeLogsResponse) SetNextPageToken(fv string)

func (*ListResourceChangeLogsResponse) SetResourceChangeLogs

func (*ListResourceChangeLogsResponse) String

func (*ListResourceChangeLogsResponse) Unmarshal

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

func (*ListResourceChangeLogsResponse) UnmarshalJSON

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

type ListResourceChangeLogsResponse_ErrorDetails

type ListResourceChangeLogsResponse_ErrorDetails struct {

	// region id which failed to give results.
	RegionId string `protobuf:"bytes,1,opt,name=region_id,json=regionId,proto3" json:"region_id,omitempty" firestore:"regionId"`
	// contains filtered or unexported fields
}

ErrorDetails is used when one of the queried regions fails to produce results. It is used in execution_errors field (see subfield ntt.rpc.Status.details).

func (*ListResourceChangeLogsResponse_ErrorDetails) Descriptor

Deprecated, Use ListResourceChangeLogsResponse_ErrorDetails.ProtoReflect.Descriptor instead.

func (*ListResourceChangeLogsResponse_ErrorDetails) GetRegionId

func (*ListResourceChangeLogsResponse_ErrorDetails) GotenMessage

func (*ListResourceChangeLogsResponse_ErrorDetails) GotenValidate

func (*ListResourceChangeLogsResponse_ErrorDetails) Marshal

func (*ListResourceChangeLogsResponse_ErrorDetails) MarshalJSON

func (*ListResourceChangeLogsResponse_ErrorDetails) ProtoMessage

func (*ListResourceChangeLogsResponse_ErrorDetails) ProtoReflect

func (*ListResourceChangeLogsResponse_ErrorDetails) Reset

func (*ListResourceChangeLogsResponse_ErrorDetails) SetRegionId

func (*ListResourceChangeLogsResponse_ErrorDetails) String

func (*ListResourceChangeLogsResponse_ErrorDetails) Unmarshal

func (*ListResourceChangeLogsResponse_ErrorDetails) UnmarshalJSON

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

type ResourceChangeLogServiceClient

type ResourceChangeLogServiceClient interface {
	ListResourceChangeLogs(ctx context.Context, in *ListResourceChangeLogsRequest, opts ...grpc.CallOption) (*ListResourceChangeLogsResponse, error)
	CreatePreCommittedResourceChangeLogs(ctx context.Context, in *CreatePreCommittedResourceChangeLogsRequest, opts ...grpc.CallOption) (*CreatePreCommittedResourceChangeLogsResponse, error)
	SetResourceChangeLogsCommitState(ctx context.Context, in *SetResourceChangeLogsCommitStateRequest, opts ...grpc.CallOption) (*SetResourceChangeLogsCommitStateResponse, error)
}

ResourceChangeLogServiceClient is the client API for ResourceChangeLogService.

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

type ResourceChangeLogServiceDescriptor

type ResourceChangeLogServiceDescriptor struct{}

func GetResourceChangeLogServiceDescriptor

func GetResourceChangeLogServiceDescriptor() *ResourceChangeLogServiceDescriptor

func (*ResourceChangeLogServiceDescriptor) AllMethodDescriptors

func (*ResourceChangeLogServiceDescriptor) GetApiName

func (*ResourceChangeLogServiceDescriptor) GetFullAPIName

func (d *ResourceChangeLogServiceDescriptor) GetFullAPIName() string

func (*ResourceChangeLogServiceDescriptor) GetProtoPkgName

func (d *ResourceChangeLogServiceDescriptor) GetProtoPkgName() string

func (*ResourceChangeLogServiceDescriptor) GetServiceDomain

func (d *ResourceChangeLogServiceDescriptor) GetServiceDomain() string

func (*ResourceChangeLogServiceDescriptor) GetServiceVersion

func (d *ResourceChangeLogServiceDescriptor) GetServiceVersion() string

type SetResourceChangeLogsCommitStateDescriptor

type SetResourceChangeLogsCommitStateDescriptor struct{}

func GetSetResourceChangeLogsCommitStateDescriptor

func GetSetResourceChangeLogsCommitStateDescriptor() *SetResourceChangeLogsCommitStateDescriptor

func (*SetResourceChangeLogsCommitStateDescriptor) GetApiDescriptor

func (*SetResourceChangeLogsCommitStateDescriptor) GetApiName

func (*SetResourceChangeLogsCommitStateDescriptor) GetClientMsgReflectHandle

func (*SetResourceChangeLogsCommitStateDescriptor) GetFullMethodName

func (d *SetResourceChangeLogsCommitStateDescriptor) GetFullMethodName() string

func (*SetResourceChangeLogsCommitStateDescriptor) GetMethodName

func (*SetResourceChangeLogsCommitStateDescriptor) GetProtoPkgName

func (*SetResourceChangeLogsCommitStateDescriptor) GetResourceDescriptor

func (*SetResourceChangeLogsCommitStateDescriptor) GetServerMsgReflectHandle

func (*SetResourceChangeLogsCommitStateDescriptor) GetServiceDomain

func (d *SetResourceChangeLogsCommitStateDescriptor) GetServiceDomain() string

func (*SetResourceChangeLogsCommitStateDescriptor) GetServiceVersion

func (d *SetResourceChangeLogsCommitStateDescriptor) GetServiceVersion() string

func (*SetResourceChangeLogsCommitStateDescriptor) GetVerb

func (*SetResourceChangeLogsCommitStateDescriptor) HasResource

func (*SetResourceChangeLogsCommitStateDescriptor) IsClientStream

func (*SetResourceChangeLogsCommitStateDescriptor) IsCollection

func (*SetResourceChangeLogsCommitStateDescriptor) IsPlural

func (*SetResourceChangeLogsCommitStateDescriptor) IsServerStream

func (*SetResourceChangeLogsCommitStateDescriptor) IsUnary

func (*SetResourceChangeLogsCommitStateDescriptor) NewEmptyClientMsg

func (*SetResourceChangeLogsCommitStateDescriptor) NewEmptyServerMsg

func (*SetResourceChangeLogsCommitStateDescriptor) RequestHasResourceBody

func (d *SetResourceChangeLogsCommitStateDescriptor) RequestHasResourceBody() bool

type SetResourceChangeLogsCommitStateDescriptorClientMsgHandle

type SetResourceChangeLogsCommitStateDescriptorClientMsgHandle struct{}

func (*SetResourceChangeLogsCommitStateDescriptorClientMsgHandle) ExtractCollectionName

func (*SetResourceChangeLogsCommitStateDescriptorClientMsgHandle) ExtractResourceBodies

func (*SetResourceChangeLogsCommitStateDescriptorClientMsgHandle) ExtractResourceBody

func (*SetResourceChangeLogsCommitStateDescriptorClientMsgHandle) ExtractResourceName

func (*SetResourceChangeLogsCommitStateDescriptorClientMsgHandle) ExtractResourceNames

type SetResourceChangeLogsCommitStateDescriptorServerMsgHandle

type SetResourceChangeLogsCommitStateDescriptorServerMsgHandle struct{}

func (*SetResourceChangeLogsCommitStateDescriptorServerMsgHandle) ExtractCollectionName

func (*SetResourceChangeLogsCommitStateDescriptorServerMsgHandle) ExtractResourceBodies

func (*SetResourceChangeLogsCommitStateDescriptorServerMsgHandle) ExtractResourceBody

func (*SetResourceChangeLogsCommitStateDescriptorServerMsgHandle) ExtractResourceName

func (*SetResourceChangeLogsCommitStateDescriptorServerMsgHandle) ExtractResourceNames

type SetResourceChangeLogsCommitStateRequest

type SetResourceChangeLogsCommitStateRequest struct {

	// list of resource change log keys.
	LogKeys [][]byte `protobuf:"bytes,1,rep,name=log_keys,json=logKeys,proto3" json:"log_keys,omitempty" firestore:"logKeys"`
	// Information about the service - must be same as before, used for
	// authorization purpose
	Service *common.ServiceData `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty" firestore:"service"`
	// Time of the request - must be same as in
	// CreatePreCommittedResourceChangeLogsRequest
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty" firestore:"timestamp"`
	// final state of the transaction - must be COMMITTED or ROLLED_BACK
	TxResult resource_change_log.ResourceChangeLog_TransactionInfo_State `` /* 165-byte string literal not displayed */
	// contains filtered or unexported fields
}

A request message of the [SetResourceChangeLogsCommitState](#setresourcechangelogscommitstate-method) method.

func (*SetResourceChangeLogsCommitStateRequest) Descriptor

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

Deprecated, Use SetResourceChangeLogsCommitStateRequest.ProtoReflect.Descriptor instead.

func (*SetResourceChangeLogsCommitStateRequest) GetLogKeys

func (m *SetResourceChangeLogsCommitStateRequest) GetLogKeys() [][]byte

func (*SetResourceChangeLogsCommitStateRequest) GetService

func (*SetResourceChangeLogsCommitStateRequest) GetTimestamp

func (*SetResourceChangeLogsCommitStateRequest) GetTxResult

func (*SetResourceChangeLogsCommitStateRequest) GotenMessage

func (*SetResourceChangeLogsCommitStateRequest) GotenValidate

func (obj *SetResourceChangeLogsCommitStateRequest) GotenValidate() error

func (*SetResourceChangeLogsCommitStateRequest) Marshal

func (*SetResourceChangeLogsCommitStateRequest) MarshalJSON

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

func (*SetResourceChangeLogsCommitStateRequest) ProtoMessage

func (*SetResourceChangeLogsCommitStateRequest) ProtoReflect

func (*SetResourceChangeLogsCommitStateRequest) Reset

func (*SetResourceChangeLogsCommitStateRequest) SetLogKeys

func (m *SetResourceChangeLogsCommitStateRequest) SetLogKeys(fv [][]byte)

func (*SetResourceChangeLogsCommitStateRequest) SetService

func (*SetResourceChangeLogsCommitStateRequest) SetTimestamp

func (*SetResourceChangeLogsCommitStateRequest) SetTxResult

func (*SetResourceChangeLogsCommitStateRequest) String

func (*SetResourceChangeLogsCommitStateRequest) Unmarshal

func (*SetResourceChangeLogsCommitStateRequest) UnmarshalJSON

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

type SetResourceChangeLogsCommitStateResponse

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

A response message of the [SetResourceChangeLogsCommitState](#setresourcechangelogscommitstate-method) method.

func (*SetResourceChangeLogsCommitStateResponse) Descriptor

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

Deprecated, Use SetResourceChangeLogsCommitStateResponse.ProtoReflect.Descriptor instead.

func (*SetResourceChangeLogsCommitStateResponse) GotenMessage

func (*SetResourceChangeLogsCommitStateResponse) GotenValidate

func (obj *SetResourceChangeLogsCommitStateResponse) GotenValidate() error

func (*SetResourceChangeLogsCommitStateResponse) Marshal

func (*SetResourceChangeLogsCommitStateResponse) MarshalJSON

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

func (*SetResourceChangeLogsCommitStateResponse) ProtoMessage

func (*SetResourceChangeLogsCommitStateResponse) ProtoReflect

func (*SetResourceChangeLogsCommitStateResponse) Reset

func (*SetResourceChangeLogsCommitStateResponse) String

func (*SetResourceChangeLogsCommitStateResponse) Unmarshal

func (*SetResourceChangeLogsCommitStateResponse) UnmarshalJSON

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

Jump to

Keyboard shortcuts

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