account

package
v0.1.7 Latest Latest
Warning

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

 Go to latest Published: Nov 1, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessage        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessage          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessage = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Period_name = map[int32]string{
	0: "Unspecified",
	1: "Day",
}
View Source 
var Period_value = map[string]int32{
	"Unspecified": 0,
	"Day":         1,
}
View Source 
var SinkDestinationType_name = map[int32]string{
	0: "Unspecified",
	1: "Kinesis",
}
View Source 
var SinkDestinationType_value = map[string]int32{
	"Unspecified": 0,
	"Kinesis":     1,
}
View Source 
var SinkState_name = map[int32]string{
	0: "Unspecified",
	1: "Creating",
	2: "Active",
	3: "Deleted",
	4: "Error",
}
View Source 
var SinkState_value = map[string]int32{
	"Unspecified": 0,
	"Creating":    1,
	"Active":      2,
	"Deleted":     3,
	"Error":       4,
}
View Source 
var SinkType_name = map[int32]string{
	0: "Unspecified",
	1: "AuditLog",
}
View Source 
var SinkType_value = map[string]int32{
	"Unspecified": 0,
	"AuditLog":    1,
}
View Source 
var State_name = map[int32]string{
	0:  "Unspecified",
	1:  "Activating",
	2:  "ActivationFailed",
	3:  "Active",
	4:  "Updating",
	5:  "UpdateFailed",
	6:  "Deleting",
	7:  "DeleteFailed",
	8:  "Deleted",
	9:  "Suspending",
	10: "SuspendFailed",
	11: "Suspended",
}
View Source 
var State_value = map[string]int32{
	"Unspecified":      0,
	"Activating":       1,
	"ActivationFailed": 2,
	"Active":           3,
	"Updating":         4,
	"UpdateFailed":     5,
	"Deleting":         6,
	"DeleteFailed":     7,
	"Deleted":          8,
	"Suspending":       9,
	"SuspendFailed":    10,
	"Suspended":        11,
}

Functions

This section is empty.

Types

type Account 

type Account struct {
	// the current version of the account specification
	// the next update request will have to include this version
	ResourceVersion string `protobuf:"bytes,1,opt,name=resource_version,json=resourceVersion,proto3" json:"resource_version,omitempty"`
	// the account specification
	Spec *AccountSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	// the current state of the account
	State State `protobuf:"varint,3,opt,name=state,proto3,enum=api.account.v1.State" json:"state,omitempty"`
	// the id of the request that is creating/updating the account, if any
	RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// the date and time when the account was created
	CreatedTime *types.Timestamp `protobuf:"bytes,5,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"`
	// the date and time when the account was last modified
	LastModifiedTime *types.Timestamp `protobuf:"bytes,6,opt,name=last_modified_time,json=lastModifiedTime,proto3" json:"last_modified_time,omitempty"`
	// information related to account-scope metrics
	Metrics *Metrics `protobuf:"bytes,7,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// Details of the sinks under the account.  Key is the sink name, and value is the Sink object
	Sinks map[string]*Sink `` /* 151-byte string literal not displayed */
}

func (*Account) Descriptor 

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

func (*Account) Equal 

func (this *Account) Equal(that interface{}) bool

func (*Account) GetCreatedTime 

func (m *Account) GetCreatedTime() *types.Timestamp

func (*Account) GetLastModifiedTime 

func (m *Account) GetLastModifiedTime() *types.Timestamp

func (*Account) GetMetrics 

func (m *Account) GetMetrics() *Metrics

func (*Account) GetRequestId 

func (m *Account) GetRequestId() string

func (*Account) GetResourceVersion 

func (m *Account) GetResourceVersion() string

func (*Account) GetSinks 

func (m *Account) GetSinks() map[string]*Sink

func (*Account) GetSpec 

func (m *Account) GetSpec() *AccountSpec

func (*Account) GetState 

func (m *Account) GetState() State

func (*Account) GoString 

func (this *Account) GoString() string

func (*Account) Marshal 

func (m *Account) Marshal() (dAtA []byte, err error)

func (*Account) MarshalTo 

func (m *Account) MarshalTo(dAtA []byte) (int, error)

func (*Account) MarshalToSizedBuffer 

func (m *Account) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) Reset 

func (m *Account) Reset()

func (*Account) Size 

func (m *Account) Size() (n int)

func (*Account) String 

func (this *Account) String() string

func (*Account) Unmarshal 

func (m *Account) Unmarshal(dAtA []byte) error

func (*Account) XXX_DiscardUnknown 

func (m *Account) XXX_DiscardUnknown()

func (*Account) XXX_Marshal 

func (m *Account) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Account) XXX_Merge 

func (m *Account) XXX_Merge(src proto.Message)

func (*Account) XXX_Size 

func (m *Account) XXX_Size() int

func (*Account) XXX_Unmarshal 

func (m *Account) XXX_Unmarshal(b []byte) error

type AccountSpec 

type AccountSpec struct {
	Metrics *MetricsSpec `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// We plan to let user create multiple sinks for potentially different data.  Key is the sink name, and the value
	// is the SinkSpec object.
	Sinks map[string]*SinkSpec `` /* 151-byte string literal not displayed */
}

func (*AccountSpec) Descriptor 

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

func (*AccountSpec) Equal 

func (this *AccountSpec) Equal(that interface{}) bool

func (*AccountSpec) GetMetrics 

func (m *AccountSpec) GetMetrics() *MetricsSpec

func (*AccountSpec) GetSinks 

func (m *AccountSpec) GetSinks() map[string]*SinkSpec

func (*AccountSpec) GoString 

func (this *AccountSpec) GoString() string

func (*AccountSpec) Marshal 

func (m *AccountSpec) Marshal() (dAtA []byte, err error)

func (*AccountSpec) MarshalTo 

func (m *AccountSpec) MarshalTo(dAtA []byte) (int, error)

func (*AccountSpec) MarshalToSizedBuffer 

func (m *AccountSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*AccountSpec) ProtoMessage 

func (*AccountSpec) ProtoMessage()

func (*AccountSpec) Reset 

func (m *AccountSpec) Reset()

func (*AccountSpec) Size 

func (m *AccountSpec) Size() (n int)

func (*AccountSpec) String 

func (this *AccountSpec) String() string

func (*AccountSpec) Unmarshal 

func (m *AccountSpec) Unmarshal(dAtA []byte) error

func (*AccountSpec) XXX_DiscardUnknown 

func (m *AccountSpec) XXX_DiscardUnknown()

func (*AccountSpec) XXX_Marshal 

func (m *AccountSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AccountSpec) XXX_Merge 

func (m *AccountSpec) XXX_Merge(src proto.Message)

func (*AccountSpec) XXX_Size 

func (m *AccountSpec) XXX_Size() int

func (*AccountSpec) XXX_Unmarshal 

func (m *AccountSpec) XXX_Unmarshal(b []byte) error

type KinesisSpec 

type KinesisSpec struct {
	// The role Temporal Cloud assumes when writing records to Kinesis
	AssumedRole string `protobuf:"bytes,1,opt,name=assumed_role,json=assumedRole,proto3" json:"assumed_role,omitempty"`
	// Destination Kinesis endpoint arn for us to send data to.
	DestinationUri string `protobuf:"bytes,2,opt,name=destination_uri,json=destinationUri,proto3" json:"destination_uri,omitempty"`
	// The sink's region.
	Region string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
}

func (*KinesisSpec) Descriptor 

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

func (*KinesisSpec) Equal 

func (this *KinesisSpec) Equal(that interface{}) bool

func (*KinesisSpec) GetAssumedRole 

func (m *KinesisSpec) GetAssumedRole() string

func (*KinesisSpec) GetDestinationUri 

func (m *KinesisSpec) GetDestinationUri() string

func (*KinesisSpec) GetRegion 

func (m *KinesisSpec) GetRegion() string

func (*KinesisSpec) GoString 

func (this *KinesisSpec) GoString() string

func (*KinesisSpec) Marshal 

func (m *KinesisSpec) Marshal() (dAtA []byte, err error)

func (*KinesisSpec) MarshalTo 

func (m *KinesisSpec) MarshalTo(dAtA []byte) (int, error)

func (*KinesisSpec) MarshalToSizedBuffer 

func (m *KinesisSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KinesisSpec) ProtoMessage 

func (*KinesisSpec) ProtoMessage()

func (*KinesisSpec) Reset 

func (m *KinesisSpec) Reset()

func (*KinesisSpec) Size 

func (m *KinesisSpec) Size() (n int)

func (*KinesisSpec) String 

func (this *KinesisSpec) String() string

func (*KinesisSpec) Unmarshal 

func (m *KinesisSpec) Unmarshal(dAtA []byte) error

func (*KinesisSpec) XXX_DiscardUnknown 

func (m *KinesisSpec) XXX_DiscardUnknown()

func (*KinesisSpec) XXX_Marshal 

func (m *KinesisSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KinesisSpec) XXX_Merge 

func (m *KinesisSpec) XXX_Merge(src proto.Message)

func (*KinesisSpec) XXX_Size 

func (m *KinesisSpec) XXX_Size() int

func (*KinesisSpec) XXX_Unmarshal 

func (m *KinesisSpec) XXX_Unmarshal(b []byte) error

type KinesisStatus 

type KinesisStatus struct {
	// The external id we use for assuming role. Reference link
	// https://docs.aws.amazon.com/IAM/latest/UserGuide/confused-deputy.html
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	// This is for the message from third party sink e.g. Kinesis error message returned from PutRecord call.
	ErrorMessage string `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

func (*KinesisStatus) Descriptor 

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

func (*KinesisStatus) Equal 

func (this *KinesisStatus) Equal(that interface{}) bool

func (*KinesisStatus) GetErrorMessage 

func (m *KinesisStatus) GetErrorMessage() string

func (*KinesisStatus) GetExternalId 

func (m *KinesisStatus) GetExternalId() string

func (*KinesisStatus) GoString 

func (this *KinesisStatus) GoString() string

func (*KinesisStatus) Marshal 

func (m *KinesisStatus) Marshal() (dAtA []byte, err error)

func (*KinesisStatus) MarshalTo 

func (m *KinesisStatus) MarshalTo(dAtA []byte) (int, error)

func (*KinesisStatus) MarshalToSizedBuffer 

func (m *KinesisStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*KinesisStatus) ProtoMessage 

func (*KinesisStatus) ProtoMessage()

func (*KinesisStatus) Reset 

func (m *KinesisStatus) Reset()

func (*KinesisStatus) Size 

func (m *KinesisStatus) Size() (n int)

func (*KinesisStatus) String 

func (this *KinesisStatus) String() string

func (*KinesisStatus) Unmarshal 

func (m *KinesisStatus) Unmarshal(dAtA []byte) error

func (*KinesisStatus) XXX_DiscardUnknown 

func (m *KinesisStatus) XXX_DiscardUnknown()

func (*KinesisStatus) XXX_Marshal 

func (m *KinesisStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KinesisStatus) XXX_Merge 

func (m *KinesisStatus) XXX_Merge(src proto.Message)

func (*KinesisStatus) XXX_Size 

func (m *KinesisStatus) XXX_Size() int

func (*KinesisStatus) XXX_Unmarshal 

func (m *KinesisStatus) XXX_Unmarshal(b []byte) error

type MeteringEntry 

type MeteringEntry struct {
	StartTime *types.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime   *types.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// The key is metering type.
	Records map[string]*MeteringRecord `` /* 155-byte string literal not displayed */
}

func (*MeteringEntry) Descriptor 

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

func (*MeteringEntry) Equal 

func (this *MeteringEntry) Equal(that interface{}) bool

func (*MeteringEntry) GetEndTime 

func (m *MeteringEntry) GetEndTime() *types.Timestamp

func (*MeteringEntry) GetRecords 

func (m *MeteringEntry) GetRecords() map[string]*MeteringRecord

func (*MeteringEntry) GetStartTime 

func (m *MeteringEntry) GetStartTime() *types.Timestamp

func (*MeteringEntry) GoString 

func (this *MeteringEntry) GoString() string

func (*MeteringEntry) Marshal 

func (m *MeteringEntry) Marshal() (dAtA []byte, err error)

func (*MeteringEntry) MarshalTo 

func (m *MeteringEntry) MarshalTo(dAtA []byte) (int, error)

func (*MeteringEntry) MarshalToSizedBuffer 

func (m *MeteringEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MeteringEntry) ProtoMessage 

func (*MeteringEntry) ProtoMessage()

func (*MeteringEntry) Reset 

func (m *MeteringEntry) Reset()

func (*MeteringEntry) Size 

func (m *MeteringEntry) Size() (n int)

func (*MeteringEntry) String 

func (this *MeteringEntry) String() string

func (*MeteringEntry) Unmarshal 

func (m *MeteringEntry) Unmarshal(dAtA []byte) error

func (*MeteringEntry) XXX_DiscardUnknown 

func (m *MeteringEntry) XXX_DiscardUnknown()

func (*MeteringEntry) XXX_Marshal 

func (m *MeteringEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeteringEntry) XXX_Merge 

func (m *MeteringEntry) XXX_Merge(src proto.Message)

func (*MeteringEntry) XXX_Size 

func (m *MeteringEntry) XXX_Size() int

func (*MeteringEntry) XXX_Unmarshal 

func (m *MeteringEntry) XXX_Unmarshal(b []byte) error

type MeteringRecord 

type MeteringRecord struct {
	Value float64 `protobuf:"fixed64,1,opt,name=value,proto3" json:"value,omitempty"`
	Unit  string  `protobuf:"bytes,2,opt,name=unit,proto3" json:"unit,omitempty"`
}

func (*MeteringRecord) Descriptor 

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

func (*MeteringRecord) Equal 

func (this *MeteringRecord) Equal(that interface{}) bool

func (*MeteringRecord) GetUnit 

func (m *MeteringRecord) GetUnit() string

func (*MeteringRecord) GetValue 

func (m *MeteringRecord) GetValue() float64

func (*MeteringRecord) GoString 

func (this *MeteringRecord) GoString() string

func (*MeteringRecord) Marshal 

func (m *MeteringRecord) Marshal() (dAtA []byte, err error)

func (*MeteringRecord) MarshalTo 

func (m *MeteringRecord) MarshalTo(dAtA []byte) (int, error)

func (*MeteringRecord) MarshalToSizedBuffer 

func (m *MeteringRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MeteringRecord) ProtoMessage 

func (*MeteringRecord) ProtoMessage()

func (*MeteringRecord) Reset 

func (m *MeteringRecord) Reset()

func (*MeteringRecord) Size 

func (m *MeteringRecord) Size() (n int)

func (*MeteringRecord) String 

func (this *MeteringRecord) String() string

func (*MeteringRecord) Unmarshal 

func (m *MeteringRecord) Unmarshal(dAtA []byte) error

func (*MeteringRecord) XXX_DiscardUnknown 

func (m *MeteringRecord) XXX_DiscardUnknown()

func (*MeteringRecord) XXX_Marshal 

func (m *MeteringRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MeteringRecord) XXX_Merge 

func (m *MeteringRecord) XXX_Merge(src proto.Message)

func (*MeteringRecord) XXX_Size 

func (m *MeteringRecord) XXX_Size() int

func (*MeteringRecord) XXX_Unmarshal 

func (m *MeteringRecord) XXX_Unmarshal(b []byte) error

type Metrics 

type Metrics struct {
	// prometheus metrics endpoint uri (this is only populated if the AccountSpec has metrics enabled)
	Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
}

func (*Metrics) Descriptor 

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

func (*Metrics) Equal 

func (this *Metrics) Equal(that interface{}) bool

func (*Metrics) GetUri 

func (m *Metrics) GetUri() string

func (*Metrics) GoString 

func (this *Metrics) GoString() string

func (*Metrics) Marshal 

func (m *Metrics) Marshal() (dAtA []byte, err error)

func (*Metrics) MarshalTo 

func (m *Metrics) MarshalTo(dAtA []byte) (int, error)

func (*Metrics) MarshalToSizedBuffer 

func (m *Metrics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) Size 

func (m *Metrics) Size() (n int)

func (*Metrics) String 

func (this *Metrics) String() string

func (*Metrics) Unmarshal 

func (m *Metrics) Unmarshal(dAtA []byte) error

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge 

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type MetricsSpec 

type MetricsSpec struct {
	// enables the endpoint from which clients can scrape all their namespace metrics
	Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// base64 encoded ca cert(s) used to authenticate clients connecting to the metrics endpoint
	AcceptedClientCa string `protobuf:"bytes,2,opt,name=accepted_client_ca,json=acceptedClientCa,proto3" json:"accepted_client_ca,omitempty"`
}

func (*MetricsSpec) Descriptor 

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

func (*MetricsSpec) Equal 

func (this *MetricsSpec) Equal(that interface{}) bool

func (*MetricsSpec) GetAcceptedClientCa 

func (m *MetricsSpec) GetAcceptedClientCa() string

func (*MetricsSpec) GetEnabled 

func (m *MetricsSpec) GetEnabled() bool

func (*MetricsSpec) GoString 

func (this *MetricsSpec) GoString() string

func (*MetricsSpec) Marshal 

func (m *MetricsSpec) Marshal() (dAtA []byte, err error)

func (*MetricsSpec) MarshalTo 

func (m *MetricsSpec) MarshalTo(dAtA []byte) (int, error)

func (*MetricsSpec) MarshalToSizedBuffer 

func (m *MetricsSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetricsSpec) ProtoMessage 

func (*MetricsSpec) ProtoMessage()

func (*MetricsSpec) Reset 

func (m *MetricsSpec) Reset()

func (*MetricsSpec) Size 

func (m *MetricsSpec) Size() (n int)

func (*MetricsSpec) String 

func (this *MetricsSpec) String() string

func (*MetricsSpec) Unmarshal 

func (m *MetricsSpec) Unmarshal(dAtA []byte) error

func (*MetricsSpec) XXX_DiscardUnknown 

func (m *MetricsSpec) XXX_DiscardUnknown()

func (*MetricsSpec) XXX_Marshal 

func (m *MetricsSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetricsSpec) XXX_Merge 

func (m *MetricsSpec) XXX_Merge(src proto.Message)

func (*MetricsSpec) XXX_Size 

func (m *MetricsSpec) XXX_Size() int

func (*MetricsSpec) XXX_Unmarshal 

func (m *MetricsSpec) XXX_Unmarshal(b []byte) error

type NamespaceUsageRecord 

type NamespaceUsageRecord struct {
	// the namespace
	Namespace string         `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Entry     *MeteringEntry `protobuf:"bytes,2,opt,name=entry,proto3" json:"entry,omitempty"`
}

func (*NamespaceUsageRecord) Descriptor 

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

func (*NamespaceUsageRecord) Equal 

func (this *NamespaceUsageRecord) Equal(that interface{}) bool

func (*NamespaceUsageRecord) GetEntry 

func (m *NamespaceUsageRecord) GetEntry() *MeteringEntry

func (*NamespaceUsageRecord) GetNamespace 

func (m *NamespaceUsageRecord) GetNamespace() string

func (*NamespaceUsageRecord) GoString 

func (this *NamespaceUsageRecord) GoString() string

func (*NamespaceUsageRecord) Marshal 

func (m *NamespaceUsageRecord) Marshal() (dAtA []byte, err error)

func (*NamespaceUsageRecord) MarshalTo 

func (m *NamespaceUsageRecord) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceUsageRecord) MarshalToSizedBuffer 

func (m *NamespaceUsageRecord) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NamespaceUsageRecord) ProtoMessage 

func (*NamespaceUsageRecord) ProtoMessage()

func (*NamespaceUsageRecord) Reset 

func (m *NamespaceUsageRecord) Reset()

func (*NamespaceUsageRecord) Size 

func (m *NamespaceUsageRecord) Size() (n int)

func (*NamespaceUsageRecord) String 

func (this *NamespaceUsageRecord) String() string

func (*NamespaceUsageRecord) Unmarshal 

func (m *NamespaceUsageRecord) Unmarshal(dAtA []byte) error

func (*NamespaceUsageRecord) XXX_DiscardUnknown 

func (m *NamespaceUsageRecord) XXX_DiscardUnknown()

func (*NamespaceUsageRecord) XXX_Marshal 

func (m *NamespaceUsageRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NamespaceUsageRecord) XXX_Merge 

func (m *NamespaceUsageRecord) XXX_Merge(src proto.Message)

func (*NamespaceUsageRecord) XXX_Size 

func (m *NamespaceUsageRecord) XXX_Size() int

func (*NamespaceUsageRecord) XXX_Unmarshal 

func (m *NamespaceUsageRecord) XXX_Unmarshal(b []byte) error

type Period 

type Period int32
const (
	PERIOD_UNSPECIFIED Period = 0
	PERIOD_DAY         Period = 1
)

func (Period) EnumDescriptor 

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

func (Period) String 

func (x Period) String() string

type Sink 

type Sink struct {
	// Name of the sink e.g. "audit_log_01"
	Sink    string    `protobuf:"bytes,1,opt,name=sink,proto3" json:"sink,omitempty"`
	State   SinkState `protobuf:"varint,2,opt,name=state,proto3,enum=api.account.v1.SinkState" json:"state,omitempty"`
	Message string    `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Last succeeded data sent timestamp, this is used to get the start time of backfill if necessary.
	LastSucceededTime *types.Timestamp `protobuf:"bytes,4,opt,name=last_succeeded_time,json=lastSucceededTime,proto3" json:"last_succeeded_time,omitempty"`
	Status            *KinesisStatus   `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
}

func (*Sink) Descriptor 

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

func (*Sink) Equal 

func (this *Sink) Equal(that interface{}) bool

func (*Sink) GetLastSucceededTime 

func (m *Sink) GetLastSucceededTime() *types.Timestamp

func (*Sink) GetMessage 

func (m *Sink) GetMessage() string

func (*Sink) GetSink 

func (m *Sink) GetSink() string

func (*Sink) GetState 

func (m *Sink) GetState() SinkState

func (*Sink) GetStatus 

func (m *Sink) GetStatus() *KinesisStatus

func (*Sink) GoString 

func (this *Sink) GoString() string

func (*Sink) Marshal 

func (m *Sink) Marshal() (dAtA []byte, err error)

func (*Sink) MarshalTo 

func (m *Sink) MarshalTo(dAtA []byte) (int, error)

func (*Sink) MarshalToSizedBuffer 

func (m *Sink) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sink) ProtoMessage 

func (*Sink) ProtoMessage()

func (*Sink) Reset 

func (m *Sink) Reset()

func (*Sink) Size 

func (m *Sink) Size() (n int)

func (*Sink) String 

func (this *Sink) String() string

func (*Sink) Unmarshal 

func (m *Sink) Unmarshal(dAtA []byte) error

func (*Sink) XXX_DiscardUnknown 

func (m *Sink) XXX_DiscardUnknown()

func (*Sink) XXX_Marshal 

func (m *Sink) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sink) XXX_Merge 

func (m *Sink) XXX_Merge(src proto.Message)

func (*Sink) XXX_Size 

func (m *Sink) XXX_Size() int

func (*Sink) XXX_Unmarshal 

func (m *Sink) XXX_Unmarshal(b []byte) error

type SinkDestinationType 

type SinkDestinationType int32
const (
	SINK_DESTINATION_TYPE_UNSPECIFIED SinkDestinationType = 0
	SINK_DESTINATION_TYPE_KINESIS     SinkDestinationType = 1
)

func (SinkDestinationType) EnumDescriptor 

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

func (SinkDestinationType) String 

func (x SinkDestinationType) String() string

type SinkSpec 

type SinkSpec struct {
	// Name of the sink e.g. "audit_log_01"
	Sink string `protobuf:"bytes,1,opt,name=sink,proto3" json:"sink,omitempty"`
	// Type of the sink. For now only AuditLog type is supported
	SinkType SinkType `protobuf:"varint,2,opt,name=sink_type,json=sinkType,proto3,enum=api.account.v1.SinkType" json:"sink_type,omitempty"`
	// The receiving service type.  For now only support Kinesis destination is supported.
	DestinationType SinkDestinationType `` /* 147-byte string literal not displayed */
	KinesisSink     *KinesisSpec        `protobuf:"bytes,4,opt,name=kinesis_sink,json=kinesisSink,proto3" json:"kinesis_sink,omitempty"`
}

func (*SinkSpec) Descriptor 

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

func (*SinkSpec) Equal 

func (this *SinkSpec) Equal(that interface{}) bool

func (*SinkSpec) GetDestinationType 

func (m *SinkSpec) GetDestinationType() SinkDestinationType

func (*SinkSpec) GetKinesisSink 

func (m *SinkSpec) GetKinesisSink() *KinesisSpec

func (*SinkSpec) GetSink 

func (m *SinkSpec) GetSink() string

func (*SinkSpec) GetSinkType 

func (m *SinkSpec) GetSinkType() SinkType

func (*SinkSpec) GoString 

func (this *SinkSpec) GoString() string

func (*SinkSpec) Marshal 

func (m *SinkSpec) Marshal() (dAtA []byte, err error)

func (*SinkSpec) MarshalTo 

func (m *SinkSpec) MarshalTo(dAtA []byte) (int, error)

func (*SinkSpec) MarshalToSizedBuffer 

func (m *SinkSpec) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SinkSpec) ProtoMessage 

func (*SinkSpec) ProtoMessage()

func (*SinkSpec) Reset 

func (m *SinkSpec) Reset()

func (*SinkSpec) Size 

func (m *SinkSpec) Size() (n int)

func (*SinkSpec) String 

func (this *SinkSpec) String() string

func (*SinkSpec) Unmarshal 

func (m *SinkSpec) Unmarshal(dAtA []byte) error

func (*SinkSpec) XXX_DiscardUnknown 

func (m *SinkSpec) XXX_DiscardUnknown()

func (*SinkSpec) XXX_Marshal 

func (m *SinkSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SinkSpec) XXX_Merge 

func (m *SinkSpec) XXX_Merge(src proto.Message)

func (*SinkSpec) XXX_Size 

func (m *SinkSpec) XXX_Size() int

func (*SinkSpec) XXX_Unmarshal 

func (m *SinkSpec) XXX_Unmarshal(b []byte) error

type SinkState 

type SinkState int32
const (
	SINK_STATE_UNSPECIFIED SinkState = 0
	// The sink is in the process of creation
	SINK_STATE_CREATING SinkState = 1
	// The sink is active
	SINK_STATE_ACTIVE SinkState = 2
	// The sink is deleted
	SINK_STATE_DELETED SinkState = 3
	// The sink has error and cannot receive logs.
	SINK_STATE_ERROR SinkState = 4
)

func (SinkState) EnumDescriptor 

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

func (SinkState) String 

func (x SinkState) String() string

type SinkType 

type SinkType int32
const (
	SINK_TYPE_UNSPECIFIED SinkType = 0
	SINK_TYPE_AUDIT_LOG   SinkType = 1
)

func (SinkType) EnumDescriptor 

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

func (SinkType) String 

func (x SinkType) String() string

type State 

type State int32
const (
	STATE_UNSPECIFIED       State = 0
	STATE_ACTIVATING        State = 1
	STATE_ACTIVATION_FAILED State = 2
	STATE_ACTIVE            State = 3
	STATE_UPDATING          State = 4
	STATE_UPDATE_FAILED     State = 5
	STATE_DELETING          State = 6
	STATE_DELETE_FAILED     State = 7
	STATE_DELETED           State = 8
	STATE_SUSPENDING        State = 9
	STATE_SUSPEND_FAILED    State = 10
	STATE_SUSPENDED         State = 11
)

func (State) EnumDescriptor 

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

func (State) String 

func (x State) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.