logging

package
v0.0.0-...-5fa7aab Latest Latest
Warning

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

Go to latest
Published: May 2, 2024 License: MIT Imports: 18 Imported by: 8

Documentation

Index

Constants

View Source
const (
	ExportService_Run_FullMethodName                  = "/yandex.cloud.logging.v1.ExportService/Run"
	ExportService_Get_FullMethodName                  = "/yandex.cloud.logging.v1.ExportService/Get"
	ExportService_List_FullMethodName                 = "/yandex.cloud.logging.v1.ExportService/List"
	ExportService_Create_FullMethodName               = "/yandex.cloud.logging.v1.ExportService/Create"
	ExportService_Update_FullMethodName               = "/yandex.cloud.logging.v1.ExportService/Update"
	ExportService_Delete_FullMethodName               = "/yandex.cloud.logging.v1.ExportService/Delete"
	ExportService_ListOperations_FullMethodName       = "/yandex.cloud.logging.v1.ExportService/ListOperations"
	ExportService_ListAccessBindings_FullMethodName   = "/yandex.cloud.logging.v1.ExportService/ListAccessBindings"
	ExportService_SetAccessBindings_FullMethodName    = "/yandex.cloud.logging.v1.ExportService/SetAccessBindings"
	ExportService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.logging.v1.ExportService/UpdateAccessBindings"
)
View Source
const (
	LogGroupService_Get_FullMethodName                  = "/yandex.cloud.logging.v1.LogGroupService/Get"
	LogGroupService_Stats_FullMethodName                = "/yandex.cloud.logging.v1.LogGroupService/Stats"
	LogGroupService_List_FullMethodName                 = "/yandex.cloud.logging.v1.LogGroupService/List"
	LogGroupService_Create_FullMethodName               = "/yandex.cloud.logging.v1.LogGroupService/Create"
	LogGroupService_Update_FullMethodName               = "/yandex.cloud.logging.v1.LogGroupService/Update"
	LogGroupService_Delete_FullMethodName               = "/yandex.cloud.logging.v1.LogGroupService/Delete"
	LogGroupService_ListResources_FullMethodName        = "/yandex.cloud.logging.v1.LogGroupService/ListResources"
	LogGroupService_ListOperations_FullMethodName       = "/yandex.cloud.logging.v1.LogGroupService/ListOperations"
	LogGroupService_ListAccessBindings_FullMethodName   = "/yandex.cloud.logging.v1.LogGroupService/ListAccessBindings"
	LogGroupService_SetAccessBindings_FullMethodName    = "/yandex.cloud.logging.v1.LogGroupService/SetAccessBindings"
	LogGroupService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.logging.v1.LogGroupService/UpdateAccessBindings"
)
View Source
const (
	SinkService_Get_FullMethodName                  = "/yandex.cloud.logging.v1.SinkService/Get"
	SinkService_List_FullMethodName                 = "/yandex.cloud.logging.v1.SinkService/List"
	SinkService_Create_FullMethodName               = "/yandex.cloud.logging.v1.SinkService/Create"
	SinkService_Update_FullMethodName               = "/yandex.cloud.logging.v1.SinkService/Update"
	SinkService_Delete_FullMethodName               = "/yandex.cloud.logging.v1.SinkService/Delete"
	SinkService_ListOperations_FullMethodName       = "/yandex.cloud.logging.v1.SinkService/ListOperations"
	SinkService_ListAccessBindings_FullMethodName   = "/yandex.cloud.logging.v1.SinkService/ListAccessBindings"
	SinkService_SetAccessBindings_FullMethodName    = "/yandex.cloud.logging.v1.SinkService/SetAccessBindings"
	SinkService_UpdateAccessBindings_FullMethodName = "/yandex.cloud.logging.v1.SinkService/UpdateAccessBindings"
)
View Source
const (
	LogIngestionService_Write_FullMethodName = "/yandex.cloud.logging.v1.LogIngestionService/Write"
)
View Source
const (
	LogReadingService_Read_FullMethodName = "/yandex.cloud.logging.v1.LogReadingService/Read"
)

Variables

View Source
var (
	LogLevel_Level_name = map[int32]string{
		0: "LEVEL_UNSPECIFIED",
		1: "TRACE",
		2: "DEBUG",
		3: "INFO",
		4: "WARN",
		5: "ERROR",
		6: "FATAL",
	}
	LogLevel_Level_value = map[string]int32{
		"LEVEL_UNSPECIFIED": 0,
		"TRACE":             1,
		"DEBUG":             2,
		"INFO":              3,
		"WARN":              4,
		"ERROR":             5,
		"FATAL":             6,
	}
)

Enum value maps for LogLevel_Level.

View Source
var (
	LogGroup_Status_name = map[int32]string{
		0: "STATUS_UNSPECIFIED",
		1: "CREATING",
		2: "ACTIVE",
		3: "DELETING",
		4: "ERROR",
	}
	LogGroup_Status_value = map[string]int32{
		"STATUS_UNSPECIFIED": 0,
		"CREATING":           1,
		"ACTIVE":             2,
		"DELETING":           3,
		"ERROR":              4,
	}
)

Enum value maps for LogGroup_Status.

View Source
var ExportService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.logging.v1.ExportService",
	HandlerType: (*ExportServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Run",
			Handler:    _ExportService_Run_Handler,
		},
		{
			MethodName: "Get",
			Handler:    _ExportService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _ExportService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ExportService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _ExportService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ExportService_Delete_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _ExportService_ListOperations_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _ExportService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _ExportService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _ExportService_UpdateAccessBindings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/logging/v1/export_service.proto",
}

ExportService_ServiceDesc is the grpc.ServiceDesc for ExportService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_yandex_cloud_logging_v1_export_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_export_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_entry_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_group_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_group_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_ingestion_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_reading_service_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_log_resource_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_sink_proto protoreflect.FileDescriptor
View Source
var File_yandex_cloud_logging_v1_sink_service_proto protoreflect.FileDescriptor
View Source
var LogGroupService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.logging.v1.LogGroupService",
	HandlerType: (*LogGroupServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _LogGroupService_Get_Handler,
		},
		{
			MethodName: "Stats",
			Handler:    _LogGroupService_Stats_Handler,
		},
		{
			MethodName: "List",
			Handler:    _LogGroupService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _LogGroupService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _LogGroupService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _LogGroupService_Delete_Handler,
		},
		{
			MethodName: "ListResources",
			Handler:    _LogGroupService_ListResources_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _LogGroupService_ListOperations_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _LogGroupService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _LogGroupService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _LogGroupService_UpdateAccessBindings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/logging/v1/log_group_service.proto",
}

LogGroupService_ServiceDesc is the grpc.ServiceDesc for LogGroupService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var LogIngestionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.logging.v1.LogIngestionService",
	HandlerType: (*LogIngestionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Write",
			Handler:    _LogIngestionService_Write_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/logging/v1/log_ingestion_service.proto",
}

LogIngestionService_ServiceDesc is the grpc.ServiceDesc for LogIngestionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var LogReadingService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.logging.v1.LogReadingService",
	HandlerType: (*LogReadingServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Read",
			Handler:    _LogReadingService_Read_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/logging/v1/log_reading_service.proto",
}

LogReadingService_ServiceDesc is the grpc.ServiceDesc for LogReadingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var SinkService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "yandex.cloud.logging.v1.SinkService",
	HandlerType: (*SinkServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _SinkService_Get_Handler,
		},
		{
			MethodName: "List",
			Handler:    _SinkService_List_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _SinkService_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _SinkService_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _SinkService_Delete_Handler,
		},
		{
			MethodName: "ListOperations",
			Handler:    _SinkService_ListOperations_Handler,
		},
		{
			MethodName: "ListAccessBindings",
			Handler:    _SinkService_ListAccessBindings_Handler,
		},
		{
			MethodName: "SetAccessBindings",
			Handler:    _SinkService_SetAccessBindings_Handler,
		},
		{
			MethodName: "UpdateAccessBindings",
			Handler:    _SinkService_UpdateAccessBindings_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "yandex/cloud/logging/v1/sink_service.proto",
}

SinkService_ServiceDesc is the grpc.ServiceDesc for SinkService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterExportServiceServer

func RegisterExportServiceServer(s grpc.ServiceRegistrar, srv ExportServiceServer)

func RegisterLogGroupServiceServer

func RegisterLogGroupServiceServer(s grpc.ServiceRegistrar, srv LogGroupServiceServer)

func RegisterLogIngestionServiceServer

func RegisterLogIngestionServiceServer(s grpc.ServiceRegistrar, srv LogIngestionServiceServer)

func RegisterLogReadingServiceServer

func RegisterLogReadingServiceServer(s grpc.ServiceRegistrar, srv LogReadingServiceServer)

func RegisterSinkServiceServer

func RegisterSinkServiceServer(s grpc.ServiceRegistrar, srv SinkServiceServer)

Types

type CreateExportMetadata

type CreateExportMetadata struct {

	// ID of the export being created.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateExportMetadata) Descriptor deprecated

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

Deprecated: Use CreateExportMetadata.ProtoReflect.Descriptor instead.

func (*CreateExportMetadata) GetExportId

func (x *CreateExportMetadata) GetExportId() string

func (*CreateExportMetadata) ProtoMessage

func (*CreateExportMetadata) ProtoMessage()

func (*CreateExportMetadata) ProtoReflect

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

func (*CreateExportMetadata) Reset

func (x *CreateExportMetadata) Reset()

func (*CreateExportMetadata) SetExportId

func (m *CreateExportMetadata) SetExportId(v string)

func (*CreateExportMetadata) String

func (x *CreateExportMetadata) String() string

type CreateExportRequest

type CreateExportRequest struct {

	// ID of the folder to create a export in.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the export.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the export.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Export labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Logging Group ID logs exported from
	GroupId string `protobuf:"bytes,5,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// Logging Sink ID logs exported to
	SinkId string `protobuf:"bytes,6,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// Parameters for logs filtration
	Params *ExportParams `protobuf:"bytes,7,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateExportRequest) Descriptor deprecated

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

Deprecated: Use CreateExportRequest.ProtoReflect.Descriptor instead.

func (*CreateExportRequest) GetDescription

func (x *CreateExportRequest) GetDescription() string

func (*CreateExportRequest) GetFolderId

func (x *CreateExportRequest) GetFolderId() string

func (*CreateExportRequest) GetGroupId

func (x *CreateExportRequest) GetGroupId() string

func (*CreateExportRequest) GetLabels

func (x *CreateExportRequest) GetLabels() map[string]string

func (*CreateExportRequest) GetName

func (x *CreateExportRequest) GetName() string

func (*CreateExportRequest) GetParams

func (x *CreateExportRequest) GetParams() *ExportParams

func (*CreateExportRequest) GetSinkId

func (x *CreateExportRequest) GetSinkId() string

func (*CreateExportRequest) ProtoMessage

func (*CreateExportRequest) ProtoMessage()

func (*CreateExportRequest) ProtoReflect

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

func (*CreateExportRequest) Reset

func (x *CreateExportRequest) Reset()

func (*CreateExportRequest) SetDescription

func (m *CreateExportRequest) SetDescription(v string)

func (*CreateExportRequest) SetFolderId

func (m *CreateExportRequest) SetFolderId(v string)

func (*CreateExportRequest) SetGroupId

func (m *CreateExportRequest) SetGroupId(v string)

func (*CreateExportRequest) SetLabels

func (m *CreateExportRequest) SetLabels(v map[string]string)

func (*CreateExportRequest) SetName

func (m *CreateExportRequest) SetName(v string)

func (*CreateExportRequest) SetParams

func (m *CreateExportRequest) SetParams(v *ExportParams)

func (*CreateExportRequest) SetSinkId

func (m *CreateExportRequest) SetSinkId(v string)

func (*CreateExportRequest) String

func (x *CreateExportRequest) String() string

type CreateLogGroupMetadata

type CreateLogGroupMetadata struct {

	// ID of the log group being created.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogGroupMetadata) Descriptor deprecated

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

Deprecated: Use CreateLogGroupMetadata.ProtoReflect.Descriptor instead.

func (*CreateLogGroupMetadata) GetLogGroupId

func (x *CreateLogGroupMetadata) GetLogGroupId() string

func (*CreateLogGroupMetadata) ProtoMessage

func (*CreateLogGroupMetadata) ProtoMessage()

func (*CreateLogGroupMetadata) ProtoReflect

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

func (*CreateLogGroupMetadata) Reset

func (x *CreateLogGroupMetadata) Reset()

func (*CreateLogGroupMetadata) SetLogGroupId

func (m *CreateLogGroupMetadata) SetLogGroupId(v string)

func (*CreateLogGroupMetadata) String

func (x *CreateLogGroupMetadata) String() string

type CreateLogGroupRequest

type CreateLogGroupRequest struct {

	// ID of the folder to create a log group in.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the log group.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the log group.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Log group labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Log group entry retention period.
	//
	// Entries will be present in group during this period.
	// If specified, must be non-negative.
	// Empty or zero value is treated as no limit.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,5,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"` // Data stream name
	// If specified, all log records will be written to this data stream
	DataStream string `protobuf:"bytes,6,opt,name=data_stream,json=dataStream,proto3" json:"data_stream,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogGroupRequest) Descriptor deprecated

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

Deprecated: Use CreateLogGroupRequest.ProtoReflect.Descriptor instead.

func (*CreateLogGroupRequest) GetDataStream

func (x *CreateLogGroupRequest) GetDataStream() string

func (*CreateLogGroupRequest) GetDescription

func (x *CreateLogGroupRequest) GetDescription() string

func (*CreateLogGroupRequest) GetFolderId

func (x *CreateLogGroupRequest) GetFolderId() string

func (*CreateLogGroupRequest) GetLabels

func (x *CreateLogGroupRequest) GetLabels() map[string]string

func (*CreateLogGroupRequest) GetName

func (x *CreateLogGroupRequest) GetName() string

func (*CreateLogGroupRequest) GetRetentionPeriod

func (x *CreateLogGroupRequest) GetRetentionPeriod() *durationpb.Duration

func (*CreateLogGroupRequest) ProtoMessage

func (*CreateLogGroupRequest) ProtoMessage()

func (*CreateLogGroupRequest) ProtoReflect

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

func (*CreateLogGroupRequest) Reset

func (x *CreateLogGroupRequest) Reset()

func (*CreateLogGroupRequest) SetDataStream

func (m *CreateLogGroupRequest) SetDataStream(v string)

func (*CreateLogGroupRequest) SetDescription

func (m *CreateLogGroupRequest) SetDescription(v string)

func (*CreateLogGroupRequest) SetFolderId

func (m *CreateLogGroupRequest) SetFolderId(v string)

func (*CreateLogGroupRequest) SetLabels

func (m *CreateLogGroupRequest) SetLabels(v map[string]string)

func (*CreateLogGroupRequest) SetName

func (m *CreateLogGroupRequest) SetName(v string)

func (*CreateLogGroupRequest) SetRetentionPeriod

func (m *CreateLogGroupRequest) SetRetentionPeriod(v *durationpb.Duration)

func (*CreateLogGroupRequest) String

func (x *CreateLogGroupRequest) String() string

type CreateSinkMetadata

type CreateSinkMetadata struct {

	// ID of the sink being created.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSinkMetadata) Descriptor deprecated

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

Deprecated: Use CreateSinkMetadata.ProtoReflect.Descriptor instead.

func (*CreateSinkMetadata) GetSinkId

func (x *CreateSinkMetadata) GetSinkId() string

func (*CreateSinkMetadata) ProtoMessage

func (*CreateSinkMetadata) ProtoMessage()

func (*CreateSinkMetadata) ProtoReflect

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

func (*CreateSinkMetadata) Reset

func (x *CreateSinkMetadata) Reset()

func (*CreateSinkMetadata) SetSinkId

func (m *CreateSinkMetadata) SetSinkId(v string)

func (*CreateSinkMetadata) String

func (x *CreateSinkMetadata) String() string

type CreateSinkRequest

type CreateSinkRequest struct {

	// ID of the folder to create a sink in.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Name of the sink.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the sink.
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// Sink labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Logs will be written to the sink on behalf of this service account
	ServiceAccountId string `protobuf:"bytes,5,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Logs destination
	//
	// Types that are assignable to Sink:
	//
	//	*CreateSinkRequest_Yds
	//	*CreateSinkRequest_S3
	Sink isCreateSinkRequest_Sink `protobuf_oneof:"sink"`
	// contains filtered or unexported fields
}

func (*CreateSinkRequest) Descriptor deprecated

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

Deprecated: Use CreateSinkRequest.ProtoReflect.Descriptor instead.

func (*CreateSinkRequest) GetDescription

func (x *CreateSinkRequest) GetDescription() string

func (*CreateSinkRequest) GetFolderId

func (x *CreateSinkRequest) GetFolderId() string

func (*CreateSinkRequest) GetLabels

func (x *CreateSinkRequest) GetLabels() map[string]string

func (*CreateSinkRequest) GetName

func (x *CreateSinkRequest) GetName() string

func (*CreateSinkRequest) GetS3

func (x *CreateSinkRequest) GetS3() *Sink_S3

func (*CreateSinkRequest) GetServiceAccountId

func (x *CreateSinkRequest) GetServiceAccountId() string

func (*CreateSinkRequest) GetSink

func (m *CreateSinkRequest) GetSink() isCreateSinkRequest_Sink

func (*CreateSinkRequest) GetYds

func (x *CreateSinkRequest) GetYds() *Sink_Yds

func (*CreateSinkRequest) ProtoMessage

func (*CreateSinkRequest) ProtoMessage()

func (*CreateSinkRequest) ProtoReflect

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

func (*CreateSinkRequest) Reset

func (x *CreateSinkRequest) Reset()

func (*CreateSinkRequest) SetDescription

func (m *CreateSinkRequest) SetDescription(v string)

func (*CreateSinkRequest) SetFolderId

func (m *CreateSinkRequest) SetFolderId(v string)

func (*CreateSinkRequest) SetLabels

func (m *CreateSinkRequest) SetLabels(v map[string]string)

func (*CreateSinkRequest) SetName

func (m *CreateSinkRequest) SetName(v string)

func (*CreateSinkRequest) SetS3

func (m *CreateSinkRequest) SetS3(v *Sink_S3)

func (*CreateSinkRequest) SetServiceAccountId

func (m *CreateSinkRequest) SetServiceAccountId(v string)

func (*CreateSinkRequest) SetSink

func (*CreateSinkRequest) SetYds

func (m *CreateSinkRequest) SetYds(v *Sink_Yds)

func (*CreateSinkRequest) String

func (x *CreateSinkRequest) String() string

type CreateSinkRequest_S3

type CreateSinkRequest_S3 struct {
	// Object storage
	S3 *Sink_S3 `protobuf:"bytes,7,opt,name=s3,proto3,oneof"`
}

type CreateSinkRequest_Sink

type CreateSinkRequest_Sink = isCreateSinkRequest_Sink

type CreateSinkRequest_Yds

type CreateSinkRequest_Yds struct {
	// Yandex data stream
	Yds *Sink_Yds `protobuf:"bytes,6,opt,name=yds,proto3,oneof"`
}

type Criteria

type Criteria struct {

	// ID of the log group to return.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// List of resource types to limit log entries to.
	//
	// Empty list disables filter.
	ResourceTypes []string `protobuf:"bytes,2,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	// List of resource IDs to limit log entries to.
	//
	// Empty list disables filter.
	ResourceIds []string `protobuf:"bytes,3,rep,name=resource_ids,json=resourceIds,proto3" json:"resource_ids,omitempty"`
	// Lower bound of log entries timestamps.
	Since *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=since,proto3" json:"since,omitempty"`
	// Upper bound of log entries timestamps.
	Until *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=until,proto3" json:"until,omitempty"`
	// List of log levels to limit log entries to.
	//
	// Empty list disables filter.
	Levels []LogLevel_Level `protobuf:"varint,6,rep,packed,name=levels,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"levels,omitempty"`
	// Filter expression. For details about filtering, see [documentation](/docs/logging/concepts/filter).
	Filter string `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	// List of stream names to limit log entries to.
	//
	// Empty list disables filter.
	StreamNames []string `protobuf:"bytes,10,rep,name=stream_names,json=streamNames,proto3" json:"stream_names,omitempty"`
	// The maximum number of results per page to return.
	PageSize int64 `protobuf:"varint,8,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Limits response to maximum size in bytes. Prevents gRPC resource exhaustion.
	//
	// Default value for max response size is 3.5 MiB
	MaxResponseSize int64 `protobuf:"varint,9,opt,name=max_response_size,json=maxResponseSize,proto3" json:"max_response_size,omitempty"`
	// contains filtered or unexported fields
}

Read criteria. Should be used in initial ReadRequest.

func (*Criteria) Descriptor deprecated

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

Deprecated: Use Criteria.ProtoReflect.Descriptor instead.

func (*Criteria) GetFilter

func (x *Criteria) GetFilter() string

func (*Criteria) GetLevels

func (x *Criteria) GetLevels() []LogLevel_Level

func (*Criteria) GetLogGroupId

func (x *Criteria) GetLogGroupId() string

func (*Criteria) GetMaxResponseSize

func (x *Criteria) GetMaxResponseSize() int64

func (*Criteria) GetPageSize

func (x *Criteria) GetPageSize() int64

func (*Criteria) GetResourceIds

func (x *Criteria) GetResourceIds() []string

func (*Criteria) GetResourceTypes

func (x *Criteria) GetResourceTypes() []string

func (*Criteria) GetSince

func (x *Criteria) GetSince() *timestamppb.Timestamp

func (*Criteria) GetStreamNames

func (x *Criteria) GetStreamNames() []string

func (*Criteria) GetUntil

func (x *Criteria) GetUntil() *timestamppb.Timestamp

func (*Criteria) ProtoMessage

func (*Criteria) ProtoMessage()

func (*Criteria) ProtoReflect

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

func (*Criteria) Reset

func (x *Criteria) Reset()

func (*Criteria) SetFilter

func (m *Criteria) SetFilter(v string)

func (*Criteria) SetLevels

func (m *Criteria) SetLevels(v []LogLevel_Level)

func (*Criteria) SetLogGroupId

func (m *Criteria) SetLogGroupId(v string)

func (*Criteria) SetMaxResponseSize

func (m *Criteria) SetMaxResponseSize(v int64)

func (*Criteria) SetPageSize

func (m *Criteria) SetPageSize(v int64)

func (*Criteria) SetResourceIds

func (m *Criteria) SetResourceIds(v []string)

func (*Criteria) SetResourceTypes

func (m *Criteria) SetResourceTypes(v []string)

func (*Criteria) SetSince

func (m *Criteria) SetSince(v *timestamppb.Timestamp)

func (*Criteria) SetStreamNames

func (m *Criteria) SetStreamNames(v []string)

func (*Criteria) SetUntil

func (m *Criteria) SetUntil(v *timestamppb.Timestamp)

func (*Criteria) String

func (x *Criteria) String() string

type DeleteExportMetadata

type DeleteExportMetadata struct {

	// ID of the export being deleted.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteExportMetadata) Descriptor deprecated

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

Deprecated: Use DeleteExportMetadata.ProtoReflect.Descriptor instead.

func (*DeleteExportMetadata) GetExportId

func (x *DeleteExportMetadata) GetExportId() string

func (*DeleteExportMetadata) ProtoMessage

func (*DeleteExportMetadata) ProtoMessage()

func (*DeleteExportMetadata) ProtoReflect

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

func (*DeleteExportMetadata) Reset

func (x *DeleteExportMetadata) Reset()

func (*DeleteExportMetadata) SetExportId

func (m *DeleteExportMetadata) SetExportId(v string)

func (*DeleteExportMetadata) String

func (x *DeleteExportMetadata) String() string

type DeleteExportRequest

type DeleteExportRequest struct {

	// ID of the export to delete.
	//
	// To get a export ID make a [ExportService.List] request.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteExportRequest) Descriptor deprecated

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

Deprecated: Use DeleteExportRequest.ProtoReflect.Descriptor instead.

func (*DeleteExportRequest) GetExportId

func (x *DeleteExportRequest) GetExportId() string

func (*DeleteExportRequest) ProtoMessage

func (*DeleteExportRequest) ProtoMessage()

func (*DeleteExportRequest) ProtoReflect

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

func (*DeleteExportRequest) Reset

func (x *DeleteExportRequest) Reset()

func (*DeleteExportRequest) SetExportId

func (m *DeleteExportRequest) SetExportId(v string)

func (*DeleteExportRequest) String

func (x *DeleteExportRequest) String() string

type DeleteLogGroupMetadata

type DeleteLogGroupMetadata struct {

	// ID of the log group being deleted.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLogGroupMetadata) Descriptor deprecated

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

Deprecated: Use DeleteLogGroupMetadata.ProtoReflect.Descriptor instead.

func (*DeleteLogGroupMetadata) GetLogGroupId

func (x *DeleteLogGroupMetadata) GetLogGroupId() string

func (*DeleteLogGroupMetadata) ProtoMessage

func (*DeleteLogGroupMetadata) ProtoMessage()

func (*DeleteLogGroupMetadata) ProtoReflect

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

func (*DeleteLogGroupMetadata) Reset

func (x *DeleteLogGroupMetadata) Reset()

func (*DeleteLogGroupMetadata) SetLogGroupId

func (m *DeleteLogGroupMetadata) SetLogGroupId(v string)

func (*DeleteLogGroupMetadata) String

func (x *DeleteLogGroupMetadata) String() string

type DeleteLogGroupRequest

type DeleteLogGroupRequest struct {

	// ID of the log group to delete.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteLogGroupRequest) Descriptor deprecated

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

Deprecated: Use DeleteLogGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteLogGroupRequest) GetLogGroupId

func (x *DeleteLogGroupRequest) GetLogGroupId() string

func (*DeleteLogGroupRequest) ProtoMessage

func (*DeleteLogGroupRequest) ProtoMessage()

func (*DeleteLogGroupRequest) ProtoReflect

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

func (*DeleteLogGroupRequest) Reset

func (x *DeleteLogGroupRequest) Reset()

func (*DeleteLogGroupRequest) SetLogGroupId

func (m *DeleteLogGroupRequest) SetLogGroupId(v string)

func (*DeleteLogGroupRequest) String

func (x *DeleteLogGroupRequest) String() string

type DeleteSinkMetadata

type DeleteSinkMetadata struct {

	// ID of the sink being deleted.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSinkMetadata) Descriptor deprecated

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

Deprecated: Use DeleteSinkMetadata.ProtoReflect.Descriptor instead.

func (*DeleteSinkMetadata) GetSinkId

func (x *DeleteSinkMetadata) GetSinkId() string

func (*DeleteSinkMetadata) ProtoMessage

func (*DeleteSinkMetadata) ProtoMessage()

func (*DeleteSinkMetadata) ProtoReflect

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

func (*DeleteSinkMetadata) Reset

func (x *DeleteSinkMetadata) Reset()

func (*DeleteSinkMetadata) SetSinkId

func (m *DeleteSinkMetadata) SetSinkId(v string)

func (*DeleteSinkMetadata) String

func (x *DeleteSinkMetadata) String() string

type DeleteSinkRequest

type DeleteSinkRequest struct {

	// ID of the sink to delete.
	//
	// To get a sink ID make a [SinkService.List] request.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteSinkRequest) Descriptor deprecated

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

Deprecated: Use DeleteSinkRequest.ProtoReflect.Descriptor instead.

func (*DeleteSinkRequest) GetSinkId

func (x *DeleteSinkRequest) GetSinkId() string

func (*DeleteSinkRequest) ProtoMessage

func (*DeleteSinkRequest) ProtoMessage()

func (*DeleteSinkRequest) ProtoReflect

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

func (*DeleteSinkRequest) Reset

func (x *DeleteSinkRequest) Reset()

func (*DeleteSinkRequest) SetSinkId

func (m *DeleteSinkRequest) SetSinkId(v string)

func (*DeleteSinkRequest) String

func (x *DeleteSinkRequest) String() string

type Destination

type Destination struct {

	// Entry destination.
	//
	// Types that are assignable to Destination:
	//
	//	*Destination_LogGroupId
	//	*Destination_FolderId
	Destination isDestination_Destination `protobuf_oneof:"destination"`
	// contains filtered or unexported fields
}

func (*Destination) Descriptor deprecated

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

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) GetDestination

func (m *Destination) GetDestination() isDestination_Destination

func (*Destination) GetFolderId

func (x *Destination) GetFolderId() string

func (*Destination) GetLogGroupId

func (x *Destination) GetLogGroupId() string

func (*Destination) ProtoMessage

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect

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

func (*Destination) Reset

func (x *Destination) Reset()

func (*Destination) SetDestination

func (m *Destination) SetDestination(v Destination_Destination)

func (*Destination) SetFolderId

func (m *Destination) SetFolderId(v string)

func (*Destination) SetLogGroupId

func (m *Destination) SetLogGroupId(v string)

func (*Destination) String

func (x *Destination) String() string

type Destination_Destination

type Destination_Destination = isDestination_Destination

type Destination_FolderId

type Destination_FolderId struct {
	// Entry should be written to default log group for the folder.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3,oneof"`
}

type Destination_LogGroupId

type Destination_LogGroupId struct {
	// Entry should be written to log group resolved by ID.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3,oneof"`
}

type Export

type Export struct {

	// Export ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Export folder ID.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Export cloud ID.
	CloudId string `protobuf:"bytes,3,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Export creation time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Export name.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Export description.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Export lables.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Group logs are exported from.
	GroupId string `protobuf:"bytes,8,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// Sink logs are exported to.
	SinkId string `protobuf:"bytes,9,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// Parameters of logs filtration.
	Params *ExportParams `protobuf:"bytes,10,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Export) Descriptor deprecated

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

Deprecated: Use Export.ProtoReflect.Descriptor instead.

func (*Export) GetCloudId

func (x *Export) GetCloudId() string

func (*Export) GetCreatedAt

func (x *Export) GetCreatedAt() *timestamppb.Timestamp

func (*Export) GetDescription

func (x *Export) GetDescription() string

func (*Export) GetFolderId

func (x *Export) GetFolderId() string

func (*Export) GetGroupId

func (x *Export) GetGroupId() string

func (*Export) GetId

func (x *Export) GetId() string

func (*Export) GetLabels

func (x *Export) GetLabels() map[string]string

func (*Export) GetName

func (x *Export) GetName() string

func (*Export) GetParams

func (x *Export) GetParams() *ExportParams

func (*Export) GetSinkId

func (x *Export) GetSinkId() string

func (*Export) ProtoMessage

func (*Export) ProtoMessage()

func (*Export) ProtoReflect

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

func (*Export) Reset

func (x *Export) Reset()

func (*Export) SetCloudId

func (m *Export) SetCloudId(v string)

func (*Export) SetCreatedAt

func (m *Export) SetCreatedAt(v *timestamppb.Timestamp)

func (*Export) SetDescription

func (m *Export) SetDescription(v string)

func (*Export) SetFolderId

func (m *Export) SetFolderId(v string)

func (*Export) SetGroupId

func (m *Export) SetGroupId(v string)

func (*Export) SetId

func (m *Export) SetId(v string)

func (*Export) SetLabels

func (m *Export) SetLabels(v map[string]string)

func (*Export) SetName

func (m *Export) SetName(v string)

func (*Export) SetParams

func (m *Export) SetParams(v *ExportParams)

func (*Export) SetSinkId

func (m *Export) SetSinkId(v string)

func (*Export) String

func (x *Export) String() string

type ExportParams

type ExportParams struct {
	ResourceTypes []string         `protobuf:"bytes,1,rep,name=resource_types,json=resourceTypes,proto3" json:"resource_types,omitempty"`
	ResourceIds   []string         `protobuf:"bytes,2,rep,name=resource_ids,json=resourceIds,proto3" json:"resource_ids,omitempty"`
	StreamNames   []string         `protobuf:"bytes,3,rep,name=stream_names,json=streamNames,proto3" json:"stream_names,omitempty"`
	Levels        []LogLevel_Level `protobuf:"varint,4,rep,packed,name=levels,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"levels,omitempty"`
	Filter        string           `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportParams) Descriptor deprecated

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

Deprecated: Use ExportParams.ProtoReflect.Descriptor instead.

func (*ExportParams) GetFilter

func (x *ExportParams) GetFilter() string

func (*ExportParams) GetLevels

func (x *ExportParams) GetLevels() []LogLevel_Level

func (*ExportParams) GetResourceIds

func (x *ExportParams) GetResourceIds() []string

func (*ExportParams) GetResourceTypes

func (x *ExportParams) GetResourceTypes() []string

func (*ExportParams) GetStreamNames

func (x *ExportParams) GetStreamNames() []string

func (*ExportParams) ProtoMessage

func (*ExportParams) ProtoMessage()

func (*ExportParams) ProtoReflect

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

func (*ExportParams) Reset

func (x *ExportParams) Reset()

func (*ExportParams) SetFilter

func (m *ExportParams) SetFilter(v string)

func (*ExportParams) SetLevels

func (m *ExportParams) SetLevels(v []LogLevel_Level)

func (*ExportParams) SetResourceIds

func (m *ExportParams) SetResourceIds(v []string)

func (*ExportParams) SetResourceTypes

func (m *ExportParams) SetResourceTypes(v []string)

func (*ExportParams) SetStreamNames

func (m *ExportParams) SetStreamNames(v []string)

func (*ExportParams) String

func (x *ExportParams) String() string

type ExportServiceClient

type ExportServiceClient interface {
	// Run new logs export from log group to sink
	Run(ctx context.Context, in *RunExportRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Returns the specified export.
	//
	// To get the list of all available exports, make a [List] request.
	Get(ctx context.Context, in *GetExportRequest, opts ...grpc.CallOption) (*Export, error)
	// Retrieves the list of exports in the specified folder.
	List(ctx context.Context, in *ListExportsRequest, opts ...grpc.CallOption) (*ListExportsResponse, error)
	// Creates a export in the specified folder.
	Create(ctx context.Context, in *CreateExportRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified export.
	Update(ctx context.Context, in *UpdateExportRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified export.
	Delete(ctx context.Context, in *DeleteExportRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified export.
	ListOperations(ctx context.Context, in *ListExportOperationsRequest, opts ...grpc.CallOption) (*ListExportOperationsResponse, error)
	// Lists existing access bindings for the specified export.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified export.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified export.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

ExportServiceClient is the client API for ExportService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ExportServiceServer

type ExportServiceServer interface {
	// Run new logs export from log group to sink
	Run(context.Context, *RunExportRequest) (*operation.Operation, error)
	// Returns the specified export.
	//
	// To get the list of all available exports, make a [List] request.
	Get(context.Context, *GetExportRequest) (*Export, error)
	// Retrieves the list of exports in the specified folder.
	List(context.Context, *ListExportsRequest) (*ListExportsResponse, error)
	// Creates a export in the specified folder.
	Create(context.Context, *CreateExportRequest) (*operation.Operation, error)
	// Updates the specified export.
	Update(context.Context, *UpdateExportRequest) (*operation.Operation, error)
	// Deletes the specified export.
	Delete(context.Context, *DeleteExportRequest) (*operation.Operation, error)
	// Lists operations for the specified export.
	ListOperations(context.Context, *ListExportOperationsRequest) (*ListExportOperationsResponse, error)
	// Lists existing access bindings for the specified export.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified export.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified export.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
}

ExportServiceServer is the server API for ExportService service. All implementations should embed UnimplementedExportServiceServer for forward compatibility

type GetExportRequest

type GetExportRequest struct {

	// ID of the export to return.
	//
	// To get a export ID make a [ExportService.List] request.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExportRequest) Descriptor deprecated

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

Deprecated: Use GetExportRequest.ProtoReflect.Descriptor instead.

func (*GetExportRequest) GetExportId

func (x *GetExportRequest) GetExportId() string

func (*GetExportRequest) ProtoMessage

func (*GetExportRequest) ProtoMessage()

func (*GetExportRequest) ProtoReflect

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

func (*GetExportRequest) Reset

func (x *GetExportRequest) Reset()

func (*GetExportRequest) SetExportId

func (m *GetExportRequest) SetExportId(v string)

func (*GetExportRequest) String

func (x *GetExportRequest) String() string

type GetLogGroupRequest

type GetLogGroupRequest struct {

	// ID of the log group to return.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogGroupRequest) Descriptor deprecated

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

Deprecated: Use GetLogGroupRequest.ProtoReflect.Descriptor instead.

func (*GetLogGroupRequest) GetLogGroupId

func (x *GetLogGroupRequest) GetLogGroupId() string

func (*GetLogGroupRequest) ProtoMessage

func (*GetLogGroupRequest) ProtoMessage()

func (*GetLogGroupRequest) ProtoReflect

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

func (*GetLogGroupRequest) Reset

func (x *GetLogGroupRequest) Reset()

func (*GetLogGroupRequest) SetLogGroupId

func (m *GetLogGroupRequest) SetLogGroupId(v string)

func (*GetLogGroupRequest) String

func (x *GetLogGroupRequest) String() string

type GetLogGroupStatsRequest

type GetLogGroupStatsRequest struct {

	// ID of the log group to return stats for.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogGroupStatsRequest) Descriptor deprecated

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

Deprecated: Use GetLogGroupStatsRequest.ProtoReflect.Descriptor instead.

func (*GetLogGroupStatsRequest) GetLogGroupId

func (x *GetLogGroupStatsRequest) GetLogGroupId() string

func (*GetLogGroupStatsRequest) ProtoMessage

func (*GetLogGroupStatsRequest) ProtoMessage()

func (*GetLogGroupStatsRequest) ProtoReflect

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

func (*GetLogGroupStatsRequest) Reset

func (x *GetLogGroupStatsRequest) Reset()

func (*GetLogGroupStatsRequest) SetLogGroupId

func (m *GetLogGroupStatsRequest) SetLogGroupId(v string)

func (*GetLogGroupStatsRequest) String

func (x *GetLogGroupStatsRequest) String() string

type GetLogGroupStatsResponse

type GetLogGroupStatsResponse struct {

	// Log group ID the stats are returned for.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// Size of data in log group in bytes.
	Bytes int64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// Amount of records in log group.
	Records int64 `protobuf:"varint,3,opt,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogGroupStatsResponse) Descriptor deprecated

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

Deprecated: Use GetLogGroupStatsResponse.ProtoReflect.Descriptor instead.

func (*GetLogGroupStatsResponse) GetBytes

func (x *GetLogGroupStatsResponse) GetBytes() int64

func (*GetLogGroupStatsResponse) GetLogGroupId

func (x *GetLogGroupStatsResponse) GetLogGroupId() string

func (*GetLogGroupStatsResponse) GetRecords

func (x *GetLogGroupStatsResponse) GetRecords() int64

func (*GetLogGroupStatsResponse) ProtoMessage

func (*GetLogGroupStatsResponse) ProtoMessage()

func (*GetLogGroupStatsResponse) ProtoReflect

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

func (*GetLogGroupStatsResponse) Reset

func (x *GetLogGroupStatsResponse) Reset()

func (*GetLogGroupStatsResponse) SetBytes

func (m *GetLogGroupStatsResponse) SetBytes(v int64)

func (*GetLogGroupStatsResponse) SetLogGroupId

func (m *GetLogGroupStatsResponse) SetLogGroupId(v string)

func (*GetLogGroupStatsResponse) SetRecords

func (m *GetLogGroupStatsResponse) SetRecords(v int64)

func (*GetLogGroupStatsResponse) String

func (x *GetLogGroupStatsResponse) String() string

type GetSinkRequest

type GetSinkRequest struct {

	// ID of the sink to return.
	//
	// To get a sink ID make a [SinkService.List] request.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSinkRequest) Descriptor deprecated

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

Deprecated: Use GetSinkRequest.ProtoReflect.Descriptor instead.

func (*GetSinkRequest) GetSinkId

func (x *GetSinkRequest) GetSinkId() string

func (*GetSinkRequest) ProtoMessage

func (*GetSinkRequest) ProtoMessage()

func (*GetSinkRequest) ProtoReflect

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

func (*GetSinkRequest) Reset

func (x *GetSinkRequest) Reset()

func (*GetSinkRequest) SetSinkId

func (m *GetSinkRequest) SetSinkId(v string)

func (*GetSinkRequest) String

func (x *GetSinkRequest) String() string

type IncomingLogEntry

type IncomingLogEntry struct {

	// Timestamp of the entry.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Entry severity.
	//
	// See [LogLevel.Level] for details.
	Level LogLevel_Level `protobuf:"varint,2,opt,name=level,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"level,omitempty"`
	// Entry text message.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Entry annotation.
	JsonPayload *structpb.Struct `protobuf:"bytes,4,opt,name=json_payload,json=jsonPayload,proto3" json:"json_payload,omitempty"`
	// Entry stream name.
	StreamName string `protobuf:"bytes,5,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// contains filtered or unexported fields
}

func (*IncomingLogEntry) Descriptor deprecated

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

Deprecated: Use IncomingLogEntry.ProtoReflect.Descriptor instead.

func (*IncomingLogEntry) GetJsonPayload

func (x *IncomingLogEntry) GetJsonPayload() *structpb.Struct

func (*IncomingLogEntry) GetLevel

func (x *IncomingLogEntry) GetLevel() LogLevel_Level

func (*IncomingLogEntry) GetMessage

func (x *IncomingLogEntry) GetMessage() string

func (*IncomingLogEntry) GetStreamName

func (x *IncomingLogEntry) GetStreamName() string

func (*IncomingLogEntry) GetTimestamp

func (x *IncomingLogEntry) GetTimestamp() *timestamppb.Timestamp

func (*IncomingLogEntry) ProtoMessage

func (*IncomingLogEntry) ProtoMessage()

func (*IncomingLogEntry) ProtoReflect

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

func (*IncomingLogEntry) Reset

func (x *IncomingLogEntry) Reset()

func (*IncomingLogEntry) SetJsonPayload

func (m *IncomingLogEntry) SetJsonPayload(v *structpb.Struct)

func (*IncomingLogEntry) SetLevel

func (m *IncomingLogEntry) SetLevel(v LogLevel_Level)

func (*IncomingLogEntry) SetMessage

func (m *IncomingLogEntry) SetMessage(v string)

func (*IncomingLogEntry) SetStreamName

func (m *IncomingLogEntry) SetStreamName(v string)

func (*IncomingLogEntry) SetTimestamp

func (m *IncomingLogEntry) SetTimestamp(v *timestamppb.Timestamp)

func (*IncomingLogEntry) String

func (x *IncomingLogEntry) String() string

type ListExportOperationsRequest

type ListExportOperationsRequest struct {

	// ID of the export to list operations for.
	//
	// To get a export ID make a [ExportService.List] request.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListExportOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListExportOperationsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can be applied to the [operation.Operation.description], [operation.Operation.created_at], [operation.Operation.modified_at], [operation.Operation.created_by], [operation.Operation.done] fields.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Examples of a filter: `done=false`, `created_by='John.Doe'`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExportOperationsRequest) Descriptor deprecated

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

Deprecated: Use ListExportOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListExportOperationsRequest) GetExportId

func (x *ListExportOperationsRequest) GetExportId() string

func (*ListExportOperationsRequest) GetFilter

func (x *ListExportOperationsRequest) GetFilter() string

func (*ListExportOperationsRequest) GetPageSize

func (x *ListExportOperationsRequest) GetPageSize() int64

func (*ListExportOperationsRequest) GetPageToken

func (x *ListExportOperationsRequest) GetPageToken() string

func (*ListExportOperationsRequest) ProtoMessage

func (*ListExportOperationsRequest) ProtoMessage()

func (*ListExportOperationsRequest) ProtoReflect

func (*ListExportOperationsRequest) Reset

func (x *ListExportOperationsRequest) Reset()

func (*ListExportOperationsRequest) SetExportId

func (m *ListExportOperationsRequest) SetExportId(v string)

func (*ListExportOperationsRequest) SetFilter

func (m *ListExportOperationsRequest) SetFilter(v string)

func (*ListExportOperationsRequest) SetPageSize

func (m *ListExportOperationsRequest) SetPageSize(v int64)

func (*ListExportOperationsRequest) SetPageToken

func (m *ListExportOperationsRequest) SetPageToken(v string)

func (*ListExportOperationsRequest) String

func (x *ListExportOperationsRequest) String() string

type ListExportOperationsResponse

type ListExportOperationsResponse struct {

	// List of operations for the specified export.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListOExportperationsRequest.page_size], use `next_page_token` as the value
	// for the [ListExportOperationsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExportOperationsResponse) Descriptor deprecated

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

Deprecated: Use ListExportOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListExportOperationsResponse) GetNextPageToken

func (x *ListExportOperationsResponse) GetNextPageToken() string

func (*ListExportOperationsResponse) GetOperations

func (x *ListExportOperationsResponse) GetOperations() []*operation.Operation

func (*ListExportOperationsResponse) ProtoMessage

func (*ListExportOperationsResponse) ProtoMessage()

func (*ListExportOperationsResponse) ProtoReflect

func (*ListExportOperationsResponse) Reset

func (x *ListExportOperationsResponse) Reset()

func (*ListExportOperationsResponse) SetNextPageToken

func (m *ListExportOperationsResponse) SetNextPageToken(v string)

func (*ListExportOperationsResponse) SetOperations

func (m *ListExportOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListExportOperationsResponse) String

type ListExportsRequest

type ListExportsRequest struct {

	// Folder ID of the exports to return.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListExportssResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListExportsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters exports listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can only be applied to the [Export.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Example of a filter: `name="my-export"`.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExportsRequest) Descriptor deprecated

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

Deprecated: Use ListExportsRequest.ProtoReflect.Descriptor instead.

func (*ListExportsRequest) GetFilter

func (x *ListExportsRequest) GetFilter() string

func (*ListExportsRequest) GetFolderId

func (x *ListExportsRequest) GetFolderId() string

func (*ListExportsRequest) GetPageSize

func (x *ListExportsRequest) GetPageSize() int64

func (*ListExportsRequest) GetPageToken

func (x *ListExportsRequest) GetPageToken() string

func (*ListExportsRequest) ProtoMessage

func (*ListExportsRequest) ProtoMessage()

func (*ListExportsRequest) ProtoReflect

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

func (*ListExportsRequest) Reset

func (x *ListExportsRequest) Reset()

func (*ListExportsRequest) SetFilter

func (m *ListExportsRequest) SetFilter(v string)

func (*ListExportsRequest) SetFolderId

func (m *ListExportsRequest) SetFolderId(v string)

func (*ListExportsRequest) SetPageSize

func (m *ListExportsRequest) SetPageSize(v int64)

func (*ListExportsRequest) SetPageToken

func (m *ListExportsRequest) SetPageToken(v string)

func (*ListExportsRequest) String

func (x *ListExportsRequest) String() string

type ListExportsResponse

type ListExportsResponse struct {

	// List of exports in the specified folder.
	Exports []*Export `protobuf:"bytes,1,rep,name=exports,proto3" json:"exports,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListExportsRequest.page_size], use `next_page_token` as the value
	// for the [ListExportsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExportsResponse) Descriptor deprecated

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

Deprecated: Use ListExportsResponse.ProtoReflect.Descriptor instead.

func (*ListExportsResponse) GetExports

func (x *ListExportsResponse) GetExports() []*Export

func (*ListExportsResponse) GetNextPageToken

func (x *ListExportsResponse) GetNextPageToken() string

func (*ListExportsResponse) ProtoMessage

func (*ListExportsResponse) ProtoMessage()

func (*ListExportsResponse) ProtoReflect

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

func (*ListExportsResponse) Reset

func (x *ListExportsResponse) Reset()

func (*ListExportsResponse) SetExports

func (m *ListExportsResponse) SetExports(v []*Export)

func (*ListExportsResponse) SetNextPageToken

func (m *ListExportsResponse) SetNextPageToken(v string)

func (*ListExportsResponse) String

func (x *ListExportsResponse) String() string

type ListLogGroupsRequest

type ListLogGroupsRequest struct {

	// Folder ID of the log groups to return.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListLogGroupsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListLogGroupsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters log groups listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can only be applied to the [LogGroup.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Example of a filter: `name=my-log-group`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogGroupsRequest) Descriptor deprecated

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

Deprecated: Use ListLogGroupsRequest.ProtoReflect.Descriptor instead.

func (*ListLogGroupsRequest) GetFilter

func (x *ListLogGroupsRequest) GetFilter() string

func (*ListLogGroupsRequest) GetFolderId

func (x *ListLogGroupsRequest) GetFolderId() string

func (*ListLogGroupsRequest) GetPageSize

func (x *ListLogGroupsRequest) GetPageSize() int64

func (*ListLogGroupsRequest) GetPageToken

func (x *ListLogGroupsRequest) GetPageToken() string

func (*ListLogGroupsRequest) ProtoMessage

func (*ListLogGroupsRequest) ProtoMessage()

func (*ListLogGroupsRequest) ProtoReflect

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

func (*ListLogGroupsRequest) Reset

func (x *ListLogGroupsRequest) Reset()

func (*ListLogGroupsRequest) SetFilter

func (m *ListLogGroupsRequest) SetFilter(v string)

func (*ListLogGroupsRequest) SetFolderId

func (m *ListLogGroupsRequest) SetFolderId(v string)

func (*ListLogGroupsRequest) SetPageSize

func (m *ListLogGroupsRequest) SetPageSize(v int64)

func (*ListLogGroupsRequest) SetPageToken

func (m *ListLogGroupsRequest) SetPageToken(v string)

func (*ListLogGroupsRequest) String

func (x *ListLogGroupsRequest) String() string

type ListLogGroupsResponse

type ListLogGroupsResponse struct {

	// List of log groups in the specified folder.
	Groups []*LogGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListLogGroupsRequest.page_size], use `next_page_token` as the value
	// for the [ListLogGroupsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogGroupsResponse) Descriptor deprecated

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

Deprecated: Use ListLogGroupsResponse.ProtoReflect.Descriptor instead.

func (*ListLogGroupsResponse) GetGroups

func (x *ListLogGroupsResponse) GetGroups() []*LogGroup

func (*ListLogGroupsResponse) GetNextPageToken

func (x *ListLogGroupsResponse) GetNextPageToken() string

func (*ListLogGroupsResponse) ProtoMessage

func (*ListLogGroupsResponse) ProtoMessage()

func (*ListLogGroupsResponse) ProtoReflect

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

func (*ListLogGroupsResponse) Reset

func (x *ListLogGroupsResponse) Reset()

func (*ListLogGroupsResponse) SetGroups

func (m *ListLogGroupsResponse) SetGroups(v []*LogGroup)

func (*ListLogGroupsResponse) SetNextPageToken

func (m *ListLogGroupsResponse) SetNextPageToken(v string)

func (*ListLogGroupsResponse) String

func (x *ListLogGroupsResponse) String() string

type ListOperationsRequest

type ListOperationsRequest struct {

	// ID of the log group to list operations for.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListOperationsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can be applied to the [operation.Operation.description], [operation.Operation.created_at], [operation.Operation.modified_at], [operation.Operation.created_by], [operation.Operation.done] fields.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Examples of a filter: `done=false`, `created_by='John.Doe'`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsRequest) Descriptor deprecated

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

Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest) GetFilter

func (x *ListOperationsRequest) GetFilter() string

func (*ListOperationsRequest) GetLogGroupId

func (x *ListOperationsRequest) GetLogGroupId() string

func (*ListOperationsRequest) GetPageSize

func (x *ListOperationsRequest) GetPageSize() int64

func (*ListOperationsRequest) GetPageToken

func (x *ListOperationsRequest) GetPageToken() string

func (*ListOperationsRequest) ProtoMessage

func (*ListOperationsRequest) ProtoMessage()

func (*ListOperationsRequest) ProtoReflect

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

func (*ListOperationsRequest) Reset

func (x *ListOperationsRequest) Reset()

func (*ListOperationsRequest) SetFilter

func (m *ListOperationsRequest) SetFilter(v string)

func (*ListOperationsRequest) SetLogGroupId

func (m *ListOperationsRequest) SetLogGroupId(v string)

func (*ListOperationsRequest) SetPageSize

func (m *ListOperationsRequest) SetPageSize(v int64)

func (*ListOperationsRequest) SetPageToken

func (m *ListOperationsRequest) SetPageToken(v string)

func (*ListOperationsRequest) String

func (x *ListOperationsRequest) String() string

type ListOperationsResponse

type ListOperationsResponse struct {

	// List of operations for the specified log group.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListOperationsRequest.page_size], use `next_page_token` as the value
	// for the [ListOperationsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsResponse) Descriptor deprecated

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

Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListOperationsResponse) GetNextPageToken

func (x *ListOperationsResponse) GetNextPageToken() string

func (*ListOperationsResponse) GetOperations

func (x *ListOperationsResponse) GetOperations() []*operation.Operation

func (*ListOperationsResponse) ProtoMessage

func (*ListOperationsResponse) ProtoMessage()

func (*ListOperationsResponse) ProtoReflect

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

func (*ListOperationsResponse) Reset

func (x *ListOperationsResponse) Reset()

func (*ListOperationsResponse) SetNextPageToken

func (m *ListOperationsResponse) SetNextPageToken(v string)

func (*ListOperationsResponse) SetOperations

func (m *ListOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListOperationsResponse) String

func (x *ListOperationsResponse) String() string

type ListResourcesRequest

type ListResourcesRequest struct {

	// ID of the log group to list resources for.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// Resource type to return resources for.
	//
	// If not specified, [ListResourcesResponse] will contain information about all resource types.
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourcesRequest) Descriptor deprecated

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

Deprecated: Use ListResourcesRequest.ProtoReflect.Descriptor instead.

func (*ListResourcesRequest) GetLogGroupId

func (x *ListResourcesRequest) GetLogGroupId() string

func (*ListResourcesRequest) GetType

func (x *ListResourcesRequest) GetType() string

func (*ListResourcesRequest) ProtoMessage

func (*ListResourcesRequest) ProtoMessage()

func (*ListResourcesRequest) ProtoReflect

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

func (*ListResourcesRequest) Reset

func (x *ListResourcesRequest) Reset()

func (*ListResourcesRequest) SetLogGroupId

func (m *ListResourcesRequest) SetLogGroupId(v string)

func (*ListResourcesRequest) SetType

func (m *ListResourcesRequest) SetType(v string)

func (*ListResourcesRequest) String

func (x *ListResourcesRequest) String() string

type ListResourcesResponse

type ListResourcesResponse struct {

	// List of resources present in log group.
	Resources []*LogGroupResource `protobuf:"bytes,1,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourcesResponse) Descriptor deprecated

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

Deprecated: Use ListResourcesResponse.ProtoReflect.Descriptor instead.

func (*ListResourcesResponse) GetResources

func (x *ListResourcesResponse) GetResources() []*LogGroupResource

func (*ListResourcesResponse) ProtoMessage

func (*ListResourcesResponse) ProtoMessage()

func (*ListResourcesResponse) ProtoReflect

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

func (*ListResourcesResponse) Reset

func (x *ListResourcesResponse) Reset()

func (*ListResourcesResponse) SetResources

func (m *ListResourcesResponse) SetResources(v []*LogGroupResource)

func (*ListResourcesResponse) String

func (x *ListResourcesResponse) String() string

type ListSinkOperationsRequest

type ListSinkOperationsRequest struct {

	// ID of the sink to list operations for.
	//
	// To get a sink ID make a [SinkService.List] request.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListSinkOperationsResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListSinkOperationsResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters resources listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can be applied to the [operation.Operation.description], [operation.Operation.created_at], [operation.Operation.modified_at], [operation.Operation.created_by], [operation.Operation.done] fields.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Examples of a filter: `done=false`, `created_by='John.Doe'`.
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinkOperationsRequest) Descriptor deprecated

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

Deprecated: Use ListSinkOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListSinkOperationsRequest) GetFilter

func (x *ListSinkOperationsRequest) GetFilter() string

func (*ListSinkOperationsRequest) GetPageSize

func (x *ListSinkOperationsRequest) GetPageSize() int64

func (*ListSinkOperationsRequest) GetPageToken

func (x *ListSinkOperationsRequest) GetPageToken() string

func (*ListSinkOperationsRequest) GetSinkId

func (x *ListSinkOperationsRequest) GetSinkId() string

func (*ListSinkOperationsRequest) ProtoMessage

func (*ListSinkOperationsRequest) ProtoMessage()

func (*ListSinkOperationsRequest) ProtoReflect

func (*ListSinkOperationsRequest) Reset

func (x *ListSinkOperationsRequest) Reset()

func (*ListSinkOperationsRequest) SetFilter

func (m *ListSinkOperationsRequest) SetFilter(v string)

func (*ListSinkOperationsRequest) SetPageSize

func (m *ListSinkOperationsRequest) SetPageSize(v int64)

func (*ListSinkOperationsRequest) SetPageToken

func (m *ListSinkOperationsRequest) SetPageToken(v string)

func (*ListSinkOperationsRequest) SetSinkId

func (m *ListSinkOperationsRequest) SetSinkId(v string)

func (*ListSinkOperationsRequest) String

func (x *ListSinkOperationsRequest) String() string

type ListSinkOperationsResponse

type ListSinkOperationsResponse struct {

	// List of operations for the specified sink.
	Operations []*operation.Operation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListOSinkperationsRequest.page_size], use `next_page_token` as the value
	// for the [ListSinkOperationsRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinkOperationsResponse) Descriptor deprecated

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

Deprecated: Use ListSinkOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListSinkOperationsResponse) GetNextPageToken

func (x *ListSinkOperationsResponse) GetNextPageToken() string

func (*ListSinkOperationsResponse) GetOperations

func (x *ListSinkOperationsResponse) GetOperations() []*operation.Operation

func (*ListSinkOperationsResponse) ProtoMessage

func (*ListSinkOperationsResponse) ProtoMessage()

func (*ListSinkOperationsResponse) ProtoReflect

func (*ListSinkOperationsResponse) Reset

func (x *ListSinkOperationsResponse) Reset()

func (*ListSinkOperationsResponse) SetNextPageToken

func (m *ListSinkOperationsResponse) SetNextPageToken(v string)

func (*ListSinkOperationsResponse) SetOperations

func (m *ListSinkOperationsResponse) SetOperations(v []*operation.Operation)

func (*ListSinkOperationsResponse) String

func (x *ListSinkOperationsResponse) String() string

type ListSinksRequest

type ListSinksRequest struct {

	// Folder ID of the sinks to return.
	//
	// To get a folder ID make a [yandex.cloud.resourcemanager.v1.FolderService.List] request.
	FolderId string `protobuf:"bytes,1,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// The maximum number of results per page to return. If the number of available
	// results is larger than `page_size`, the service returns a [ListSinkssResponse.next_page_token]
	// that can be used to get the next page of results in subsequent list requests.
	//
	// Default value: 100.
	PageSize int64 `protobuf:"varint,3,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// Page token. To get the next page of results, set `page_token` to the
	// [ListSinksResponse.next_page_token] returned by a previous list request.
	PageToken string `protobuf:"bytes,4,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// A filter expression that filters sinks listed in the response.
	//
	// The expression must specify:
	// 1. The field name. Currently filtering can only be applied to the [Sink.name] field.
	// 2. An `=` operator.
	// 3. The value in double quotes (`"`). Must be 3-63 characters long and match the regular expression `[a-z][-a-z0-9]{1,61}[a-z0-9]`.
	// Example of a filter: `name="my-sink"`.
	Filter string `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinksRequest) Descriptor deprecated

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

Deprecated: Use ListSinksRequest.ProtoReflect.Descriptor instead.

func (*ListSinksRequest) GetFilter

func (x *ListSinksRequest) GetFilter() string

func (*ListSinksRequest) GetFolderId

func (x *ListSinksRequest) GetFolderId() string

func (*ListSinksRequest) GetPageSize

func (x *ListSinksRequest) GetPageSize() int64

func (*ListSinksRequest) GetPageToken

func (x *ListSinksRequest) GetPageToken() string

func (*ListSinksRequest) ProtoMessage

func (*ListSinksRequest) ProtoMessage()

func (*ListSinksRequest) ProtoReflect

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

func (*ListSinksRequest) Reset

func (x *ListSinksRequest) Reset()

func (*ListSinksRequest) SetFilter

func (m *ListSinksRequest) SetFilter(v string)

func (*ListSinksRequest) SetFolderId

func (m *ListSinksRequest) SetFolderId(v string)

func (*ListSinksRequest) SetPageSize

func (m *ListSinksRequest) SetPageSize(v int64)

func (*ListSinksRequest) SetPageToken

func (m *ListSinksRequest) SetPageToken(v string)

func (*ListSinksRequest) String

func (x *ListSinksRequest) String() string

type ListSinksResponse

type ListSinksResponse struct {

	// List of sinks in the specified folder.
	Sinks []*Sink `protobuf:"bytes,1,rep,name=sinks,proto3" json:"sinks,omitempty"`
	// Token for getting the next page of the list. If the number of results is greater than
	// the specified [ListSinksRequest.page_size], use `next_page_token` as the value
	// for the [ListSinksRequest.page_token] parameter in the next list request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSinksResponse) Descriptor deprecated

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

Deprecated: Use ListSinksResponse.ProtoReflect.Descriptor instead.

func (*ListSinksResponse) GetNextPageToken

func (x *ListSinksResponse) GetNextPageToken() string

func (*ListSinksResponse) GetSinks

func (x *ListSinksResponse) GetSinks() []*Sink

func (*ListSinksResponse) ProtoMessage

func (*ListSinksResponse) ProtoMessage()

func (*ListSinksResponse) ProtoReflect

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

func (*ListSinksResponse) Reset

func (x *ListSinksResponse) Reset()

func (*ListSinksResponse) SetNextPageToken

func (m *ListSinksResponse) SetNextPageToken(v string)

func (*ListSinksResponse) SetSinks

func (m *ListSinksResponse) SetSinks(v []*Sink)

func (*ListSinksResponse) String

func (x *ListSinksResponse) String() string

type LogEntry

type LogEntry struct {

	// Unique entry ID.
	//
	// Useful for logs deduplication.
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// Entry resource specification.
	//
	// May contain information about source service and resource ID.
	// Also may be provided by the user.
	Resource *LogEntryResource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// Timestamp of the entry.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// Entry ingestion time observed by [LogIngestionService].
	IngestedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=ingested_at,json=ingestedAt,proto3" json:"ingested_at,omitempty"`
	// Entry save time.
	//
	// Entry is ready to be read since this moment.
	SavedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=saved_at,json=savedAt,proto3" json:"saved_at,omitempty"`
	// Entry severity.
	//
	// See [LogLevel.Level] for details.
	Level LogLevel_Level `protobuf:"varint,6,opt,name=level,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"level,omitempty"`
	// Entry text message.
	Message string `protobuf:"bytes,7,opt,name=message,proto3" json:"message,omitempty"`
	// Entry annotation.
	JsonPayload *structpb.Struct `protobuf:"bytes,8,opt,name=json_payload,json=jsonPayload,proto3" json:"json_payload,omitempty"`
	// Entry stream name.
	StreamName string `protobuf:"bytes,9,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntry) Descriptor deprecated

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

Deprecated: Use LogEntry.ProtoReflect.Descriptor instead.

func (*LogEntry) GetIngestedAt

func (x *LogEntry) GetIngestedAt() *timestamppb.Timestamp

func (*LogEntry) GetJsonPayload

func (x *LogEntry) GetJsonPayload() *structpb.Struct

func (*LogEntry) GetLevel

func (x *LogEntry) GetLevel() LogLevel_Level

func (*LogEntry) GetMessage

func (x *LogEntry) GetMessage() string

func (*LogEntry) GetResource

func (x *LogEntry) GetResource() *LogEntryResource

func (*LogEntry) GetSavedAt

func (x *LogEntry) GetSavedAt() *timestamppb.Timestamp

func (*LogEntry) GetStreamName

func (x *LogEntry) GetStreamName() string

func (*LogEntry) GetTimestamp

func (x *LogEntry) GetTimestamp() *timestamppb.Timestamp

func (*LogEntry) GetUid

func (x *LogEntry) GetUid() string

func (*LogEntry) ProtoMessage

func (*LogEntry) ProtoMessage()

func (*LogEntry) ProtoReflect

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

func (*LogEntry) Reset

func (x *LogEntry) Reset()

func (*LogEntry) SetIngestedAt

func (m *LogEntry) SetIngestedAt(v *timestamppb.Timestamp)

func (*LogEntry) SetJsonPayload

func (m *LogEntry) SetJsonPayload(v *structpb.Struct)

func (*LogEntry) SetLevel

func (m *LogEntry) SetLevel(v LogLevel_Level)

func (*LogEntry) SetMessage

func (m *LogEntry) SetMessage(v string)

func (*LogEntry) SetResource

func (m *LogEntry) SetResource(v *LogEntryResource)

func (*LogEntry) SetSavedAt

func (m *LogEntry) SetSavedAt(v *timestamppb.Timestamp)

func (*LogEntry) SetStreamName

func (m *LogEntry) SetStreamName(v string)

func (*LogEntry) SetTimestamp

func (m *LogEntry) SetTimestamp(v *timestamppb.Timestamp)

func (*LogEntry) SetUid

func (m *LogEntry) SetUid(v string)

func (*LogEntry) String

func (x *LogEntry) String() string

type LogEntryDefaults

type LogEntryDefaults struct {

	// Default entry severity.
	// Will be applied if entry level is unspecified.
	//
	// See [LogLevel.Level] for details.
	Level LogLevel_Level `protobuf:"varint,2,opt,name=level,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"level,omitempty"`
	// Default entry annotation.
	// Will be merged with entry annotation.
	// Any conflict will be resolved in favor of entry own annotation.
	JsonPayload *structpb.Struct `protobuf:"bytes,4,opt,name=json_payload,json=jsonPayload,proto3" json:"json_payload,omitempty"`
	// Entry stream name.
	StreamName string `protobuf:"bytes,5,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// contains filtered or unexported fields
}

func (*LogEntryDefaults) Descriptor deprecated

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

Deprecated: Use LogEntryDefaults.ProtoReflect.Descriptor instead.

func (*LogEntryDefaults) GetJsonPayload

func (x *LogEntryDefaults) GetJsonPayload() *structpb.Struct

func (*LogEntryDefaults) GetLevel

func (x *LogEntryDefaults) GetLevel() LogLevel_Level

func (*LogEntryDefaults) GetStreamName

func (x *LogEntryDefaults) GetStreamName() string

func (*LogEntryDefaults) ProtoMessage

func (*LogEntryDefaults) ProtoMessage()

func (*LogEntryDefaults) ProtoReflect

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

func (*LogEntryDefaults) Reset

func (x *LogEntryDefaults) Reset()

func (*LogEntryDefaults) SetJsonPayload

func (m *LogEntryDefaults) SetJsonPayload(v *structpb.Struct)

func (*LogEntryDefaults) SetLevel

func (m *LogEntryDefaults) SetLevel(v LogLevel_Level)

func (*LogEntryDefaults) SetStreamName

func (m *LogEntryDefaults) SetStreamName(v string)

func (*LogEntryDefaults) String

func (x *LogEntryDefaults) String() string

type LogEntryResource

type LogEntryResource struct {

	// Resource type, i.e., `serverless.function`
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Resource ID, i.e., ID of the function producing logs.
	Id string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Log entry resource specification.

May be used either by services and by user.

func (*LogEntryResource) Descriptor deprecated

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

Deprecated: Use LogEntryResource.ProtoReflect.Descriptor instead.

func (*LogEntryResource) GetId

func (x *LogEntryResource) GetId() string

func (*LogEntryResource) GetType

func (x *LogEntryResource) GetType() string

func (*LogEntryResource) ProtoMessage

func (*LogEntryResource) ProtoMessage()

func (*LogEntryResource) ProtoReflect

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

func (*LogEntryResource) Reset

func (x *LogEntryResource) Reset()

func (*LogEntryResource) SetId

func (m *LogEntryResource) SetId(v string)

func (*LogEntryResource) SetType

func (m *LogEntryResource) SetType(v string)

func (*LogEntryResource) String

func (x *LogEntryResource) String() string

type LogGroup

type LogGroup struct {

	// Log group ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Log group folder ID.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Log group cloud ID.
	CloudId string `protobuf:"bytes,3,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Log group creation time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Log group name.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Log group description.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Log group labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Status of the log group.
	Status LogGroup_Status `protobuf:"varint,8,opt,name=status,proto3,enum=yandex.cloud.logging.v1.LogGroup_Status" json:"status,omitempty"`
	// Log group entry retention period.
	//
	// Entries will be present in group during this period.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,9,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	// Data stream name
	DataStream string `protobuf:"bytes,10,opt,name=data_stream,json=dataStream,proto3" json:"data_stream,omitempty"`
	// contains filtered or unexported fields
}

func (*LogGroup) Descriptor deprecated

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

Deprecated: Use LogGroup.ProtoReflect.Descriptor instead.

func (*LogGroup) GetCloudId

func (x *LogGroup) GetCloudId() string

func (*LogGroup) GetCreatedAt

func (x *LogGroup) GetCreatedAt() *timestamppb.Timestamp

func (*LogGroup) GetDataStream

func (x *LogGroup) GetDataStream() string

func (*LogGroup) GetDescription

func (x *LogGroup) GetDescription() string

func (*LogGroup) GetFolderId

func (x *LogGroup) GetFolderId() string

func (*LogGroup) GetId

func (x *LogGroup) GetId() string

func (*LogGroup) GetLabels

func (x *LogGroup) GetLabels() map[string]string

func (*LogGroup) GetName

func (x *LogGroup) GetName() string

func (*LogGroup) GetRetentionPeriod

func (x *LogGroup) GetRetentionPeriod() *durationpb.Duration

func (*LogGroup) GetStatus

func (x *LogGroup) GetStatus() LogGroup_Status

func (*LogGroup) ProtoMessage

func (*LogGroup) ProtoMessage()

func (*LogGroup) ProtoReflect

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

func (*LogGroup) Reset

func (x *LogGroup) Reset()

func (*LogGroup) SetCloudId

func (m *LogGroup) SetCloudId(v string)

func (*LogGroup) SetCreatedAt

func (m *LogGroup) SetCreatedAt(v *timestamppb.Timestamp)

func (*LogGroup) SetDataStream

func (m *LogGroup) SetDataStream(v string)

func (*LogGroup) SetDescription

func (m *LogGroup) SetDescription(v string)

func (*LogGroup) SetFolderId

func (m *LogGroup) SetFolderId(v string)

func (*LogGroup) SetId

func (m *LogGroup) SetId(v string)

func (*LogGroup) SetLabels

func (m *LogGroup) SetLabels(v map[string]string)

func (*LogGroup) SetName

func (m *LogGroup) SetName(v string)

func (*LogGroup) SetRetentionPeriod

func (m *LogGroup) SetRetentionPeriod(v *durationpb.Duration)

func (*LogGroup) SetStatus

func (m *LogGroup) SetStatus(v LogGroup_Status)

func (*LogGroup) String

func (x *LogGroup) String() string

type LogGroupResource

type LogGroupResource struct {

	// Resource type.
	//
	// Collected from log entries inside log group.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// List of resource IDs with the same resource type.
	Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

Log group resource.

func (*LogGroupResource) Descriptor deprecated

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

Deprecated: Use LogGroupResource.ProtoReflect.Descriptor instead.

func (*LogGroupResource) GetIds

func (x *LogGroupResource) GetIds() []string

func (*LogGroupResource) GetType

func (x *LogGroupResource) GetType() string

func (*LogGroupResource) ProtoMessage

func (*LogGroupResource) ProtoMessage()

func (*LogGroupResource) ProtoReflect

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

func (*LogGroupResource) Reset

func (x *LogGroupResource) Reset()

func (*LogGroupResource) SetIds

func (m *LogGroupResource) SetIds(v []string)

func (*LogGroupResource) SetType

func (m *LogGroupResource) SetType(v string)

func (*LogGroupResource) String

func (x *LogGroupResource) String() string

type LogGroupServiceClient

type LogGroupServiceClient interface {
	// Returns the specified log group.
	//
	// To get the list of all available log groups, make a [List] request.
	Get(ctx context.Context, in *GetLogGroupRequest, opts ...grpc.CallOption) (*LogGroup, error)
	// Returns stats for the specified log group.
	Stats(ctx context.Context, in *GetLogGroupStatsRequest, opts ...grpc.CallOption) (*GetLogGroupStatsResponse, error)
	// Retrieves the list of log groups in the specified folder.
	List(ctx context.Context, in *ListLogGroupsRequest, opts ...grpc.CallOption) (*ListLogGroupsResponse, error)
	// Creates a log group in the specified folder.
	Create(ctx context.Context, in *CreateLogGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified log group.
	Update(ctx context.Context, in *UpdateLogGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified log group.
	Delete(ctx context.Context, in *DeleteLogGroupRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Retrieves the resources (type and IDs) in the specified log group.
	ListResources(ctx context.Context, in *ListResourcesRequest, opts ...grpc.CallOption) (*ListResourcesResponse, error)
	// Lists operations for the specified log group.
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error)
	// Lists existing access bindings for the specified log group.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified log group.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified log group.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

LogGroupServiceClient is the client API for LogGroupService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LogGroupServiceServer

type LogGroupServiceServer interface {
	// Returns the specified log group.
	//
	// To get the list of all available log groups, make a [List] request.
	Get(context.Context, *GetLogGroupRequest) (*LogGroup, error)
	// Returns stats for the specified log group.
	Stats(context.Context, *GetLogGroupStatsRequest) (*GetLogGroupStatsResponse, error)
	// Retrieves the list of log groups in the specified folder.
	List(context.Context, *ListLogGroupsRequest) (*ListLogGroupsResponse, error)
	// Creates a log group in the specified folder.
	Create(context.Context, *CreateLogGroupRequest) (*operation.Operation, error)
	// Updates the specified log group.
	Update(context.Context, *UpdateLogGroupRequest) (*operation.Operation, error)
	// Deletes the specified log group.
	Delete(context.Context, *DeleteLogGroupRequest) (*operation.Operation, error)
	// Retrieves the resources (type and IDs) in the specified log group.
	ListResources(context.Context, *ListResourcesRequest) (*ListResourcesResponse, error)
	// Lists operations for the specified log group.
	ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)
	// Lists existing access bindings for the specified log group.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified log group.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified log group.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
}

LogGroupServiceServer is the server API for LogGroupService service. All implementations should embed UnimplementedLogGroupServiceServer for forward compatibility

type LogGroup_Status

type LogGroup_Status int32

Possible log group statuses.

const (
	// Unknown status.
	//
	// Should never occur.
	LogGroup_STATUS_UNSPECIFIED LogGroup_Status = 0
	// Log group is creating.
	LogGroup_CREATING LogGroup_Status = 1
	// Log group is ready to accept messages,
	LogGroup_ACTIVE LogGroup_Status = 2
	// Log group is being deleted.
	//
	// No messages will be accepted.
	LogGroup_DELETING LogGroup_Status = 3
	// Log group is in failed state.
	LogGroup_ERROR LogGroup_Status = 4
)

func (LogGroup_Status) Descriptor

func (LogGroup_Status) Enum

func (x LogGroup_Status) Enum() *LogGroup_Status

func (LogGroup_Status) EnumDescriptor deprecated

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

Deprecated: Use LogGroup_Status.Descriptor instead.

func (LogGroup_Status) Number

func (LogGroup_Status) String

func (x LogGroup_Status) String() string

func (LogGroup_Status) Type

type LogIngestionServiceClient

type LogIngestionServiceClient interface {
	// Write log entries to specified destination.
	Write(ctx context.Context, in *WriteRequest, opts ...grpc.CallOption) (*WriteResponse, error)
}

LogIngestionServiceClient is the client API for LogIngestionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LogIngestionServiceServer

type LogIngestionServiceServer interface {
	// Write log entries to specified destination.
	Write(context.Context, *WriteRequest) (*WriteResponse, error)
}

LogIngestionServiceServer is the server API for LogIngestionService service. All implementations should embed UnimplementedLogIngestionServiceServer for forward compatibility

type LogLevel

type LogLevel struct {

	// Entry level.
	//
	// See [Level] for possible values.
	Level LogLevel_Level `protobuf:"varint,1,opt,name=level,proto3,enum=yandex.cloud.logging.v1.LogLevel_Level" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLevel) Descriptor deprecated

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

Deprecated: Use LogLevel.ProtoReflect.Descriptor instead.

func (*LogLevel) GetLevel

func (x *LogLevel) GetLevel() LogLevel_Level

func (*LogLevel) ProtoMessage

func (*LogLevel) ProtoMessage()

func (*LogLevel) ProtoReflect

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

func (*LogLevel) Reset

func (x *LogLevel) Reset()

func (*LogLevel) SetLevel

func (m *LogLevel) SetLevel(v LogLevel_Level)

func (*LogLevel) String

func (x *LogLevel) String() string

type LogLevel_Level

type LogLevel_Level int32

Possible log levels for entries.

const (
	// Default log level.
	//
	// Equivalent to not specifying log level at all.
	LogLevel_LEVEL_UNSPECIFIED LogLevel_Level = 0
	// Trace log level.
	//
	// Possible use case: verbose logging of some business logic.
	LogLevel_TRACE LogLevel_Level = 1
	// Debug log level.
	//
	// Possible use case: debugging special cases in application logic.
	LogLevel_DEBUG LogLevel_Level = 2
	// Info log level.
	//
	// Mostly used for information messages.
	LogLevel_INFO LogLevel_Level = 3
	// Warn log level.
	//
	// May be used to alert about significant events.
	LogLevel_WARN LogLevel_Level = 4
	// Error log level.
	//
	// May be used to alert about errors in infrastructure, logic, etc.
	LogLevel_ERROR LogLevel_Level = 5
	// Fatal log level.
	//
	// May be used to alert about unrecoverable failures and events.
	LogLevel_FATAL LogLevel_Level = 6
)

func (LogLevel_Level) Descriptor

func (LogLevel_Level) Enum

func (x LogLevel_Level) Enum() *LogLevel_Level

func (LogLevel_Level) EnumDescriptor deprecated

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

Deprecated: Use LogLevel_Level.Descriptor instead.

func (LogLevel_Level) Number

func (LogLevel_Level) String

func (x LogLevel_Level) String() string

func (LogLevel_Level) Type

type LogReadingServiceClient

type LogReadingServiceClient interface {
	// Read log entries from the specified log group.
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
}

LogReadingServiceClient is the client API for LogReadingService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type LogReadingServiceServer

type LogReadingServiceServer interface {
	// Read log entries from the specified log group.
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
}

LogReadingServiceServer is the server API for LogReadingService service. All implementations should embed UnimplementedLogReadingServiceServer for forward compatibility

type ReadRequest

type ReadRequest struct {

	// Read selector.
	//
	// Types that are assignable to Selector:
	//
	//	*ReadRequest_PageToken
	//	*ReadRequest_Criteria
	Selector isReadRequest_Selector `protobuf_oneof:"selector"`
	// contains filtered or unexported fields
}

func (*ReadRequest) Descriptor deprecated

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

Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.

func (*ReadRequest) GetCriteria

func (x *ReadRequest) GetCriteria() *Criteria

func (*ReadRequest) GetPageToken

func (x *ReadRequest) GetPageToken() string

func (*ReadRequest) GetSelector

func (m *ReadRequest) GetSelector() isReadRequest_Selector

func (*ReadRequest) ProtoMessage

func (*ReadRequest) ProtoMessage()

func (*ReadRequest) ProtoReflect

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

func (*ReadRequest) Reset

func (x *ReadRequest) Reset()

func (*ReadRequest) SetCriteria

func (m *ReadRequest) SetCriteria(v *Criteria)

func (*ReadRequest) SetPageToken

func (m *ReadRequest) SetPageToken(v string)

func (*ReadRequest) SetSelector

func (m *ReadRequest) SetSelector(v ReadRequest_Selector)

func (*ReadRequest) String

func (x *ReadRequest) String() string

type ReadRequest_Criteria

type ReadRequest_Criteria struct {
	// Read criteria.
	//
	// See [Criteria] for details.
	Criteria *Criteria `protobuf:"bytes,2,opt,name=criteria,proto3,oneof"`
}

type ReadRequest_PageToken

type ReadRequest_PageToken struct {
	// Page token. To get the next page of results, set `page_token` to the
	// [ReadResponse.next_page_token] or [ReadResponse.previous_page_token] returned by a previous read request.
	PageToken string `protobuf:"bytes,1,opt,name=page_token,json=pageToken,proto3,oneof"`
}

type ReadRequest_Selector

type ReadRequest_Selector = isReadRequest_Selector

type ReadResponse

type ReadResponse struct {

	// Log group ID the read was performed from.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// List of matching log entries.
	Entries []*LogEntry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// Token for getting the next page of the log entries.
	//
	// After getting log entries initially with [Criteria], you can use `next_page_token` as the value
	// for the [ReadRequest.page_token] parameter in the next read request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	NextPageToken string `protobuf:"bytes,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Token for getting the previous page of the log entries.
	//
	// After getting log entries initially with [Criteria], you can use `previous_page_token` as the value
	// for the [ReadRequest.page_token] parameter in the next read request.
	//
	// Each subsequent page will have its own `next_page_token` to continue paging through the results.
	PreviousPageToken string `protobuf:"bytes,4,opt,name=previous_page_token,json=previousPageToken,proto3" json:"previous_page_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse) Descriptor deprecated

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetEntries

func (x *ReadResponse) GetEntries() []*LogEntry

func (*ReadResponse) GetLogGroupId

func (x *ReadResponse) GetLogGroupId() string

func (*ReadResponse) GetNextPageToken

func (x *ReadResponse) GetNextPageToken() string

func (*ReadResponse) GetPreviousPageToken

func (x *ReadResponse) GetPreviousPageToken() string

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

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

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) SetEntries

func (m *ReadResponse) SetEntries(v []*LogEntry)

func (*ReadResponse) SetLogGroupId

func (m *ReadResponse) SetLogGroupId(v string)

func (*ReadResponse) SetNextPageToken

func (m *ReadResponse) SetNextPageToken(v string)

func (*ReadResponse) SetPreviousPageToken

func (m *ReadResponse) SetPreviousPageToken(v string)

func (*ReadResponse) String

func (x *ReadResponse) String() string

type RunExportDetails

type RunExportDetails struct {
	GroupId        string                 `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	SinkId         string                 `protobuf:"bytes,2,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Params         *ExportParams          `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	ResultFilename string                 `protobuf:"bytes,4,opt,name=result_filename,json=resultFilename,proto3" json:"result_filename,omitempty"`
	Since          *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=since,proto3" json:"since,omitempty"`
	Until          *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=until,proto3" json:"until,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExportDetails) Descriptor deprecated

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

Deprecated: Use RunExportDetails.ProtoReflect.Descriptor instead.

func (*RunExportDetails) GetGroupId

func (x *RunExportDetails) GetGroupId() string

func (*RunExportDetails) GetParams

func (x *RunExportDetails) GetParams() *ExportParams

func (*RunExportDetails) GetResultFilename

func (x *RunExportDetails) GetResultFilename() string

func (*RunExportDetails) GetSince

func (x *RunExportDetails) GetSince() *timestamppb.Timestamp

func (*RunExportDetails) GetSinkId

func (x *RunExportDetails) GetSinkId() string

func (*RunExportDetails) GetUntil

func (x *RunExportDetails) GetUntil() *timestamppb.Timestamp

func (*RunExportDetails) ProtoMessage

func (*RunExportDetails) ProtoMessage()

func (*RunExportDetails) ProtoReflect

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

func (*RunExportDetails) Reset

func (x *RunExportDetails) Reset()

func (*RunExportDetails) SetGroupId

func (m *RunExportDetails) SetGroupId(v string)

func (*RunExportDetails) SetParams

func (m *RunExportDetails) SetParams(v *ExportParams)

func (*RunExportDetails) SetResultFilename

func (m *RunExportDetails) SetResultFilename(v string)

func (*RunExportDetails) SetSince

func (m *RunExportDetails) SetSince(v *timestamppb.Timestamp)

func (*RunExportDetails) SetSinkId

func (m *RunExportDetails) SetSinkId(v string)

func (*RunExportDetails) SetUntil

func (m *RunExportDetails) SetUntil(v *timestamppb.Timestamp)

func (*RunExportDetails) String

func (x *RunExportDetails) String() string

type RunExportMetadata

type RunExportMetadata struct {
	GroupId        string `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	SinkId         string `protobuf:"bytes,2,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	ResultFilename string `protobuf:"bytes,3,opt,name=result_filename,json=resultFilename,proto3" json:"result_filename,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExportMetadata) Descriptor deprecated

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

Deprecated: Use RunExportMetadata.ProtoReflect.Descriptor instead.

func (*RunExportMetadata) GetGroupId

func (x *RunExportMetadata) GetGroupId() string

func (*RunExportMetadata) GetResultFilename

func (x *RunExportMetadata) GetResultFilename() string

func (*RunExportMetadata) GetSinkId

func (x *RunExportMetadata) GetSinkId() string

func (*RunExportMetadata) ProtoMessage

func (*RunExportMetadata) ProtoMessage()

func (*RunExportMetadata) ProtoReflect

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

func (*RunExportMetadata) Reset

func (x *RunExportMetadata) Reset()

func (*RunExportMetadata) SetGroupId

func (m *RunExportMetadata) SetGroupId(v string)

func (*RunExportMetadata) SetResultFilename

func (m *RunExportMetadata) SetResultFilename(v string)

func (*RunExportMetadata) SetSinkId

func (m *RunExportMetadata) SetSinkId(v string)

func (*RunExportMetadata) String

func (x *RunExportMetadata) String() string

type RunExportRequest

type RunExportRequest struct {
	GroupId        string                 `protobuf:"bytes,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	SinkId         string                 `protobuf:"bytes,2,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	Params         *ExportParams          `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	ResultFilename string                 `protobuf:"bytes,4,opt,name=result_filename,json=resultFilename,proto3" json:"result_filename,omitempty"`
	Since          *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=since,proto3" json:"since,omitempty"`
	Until          *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=until,proto3" json:"until,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExportRequest) Descriptor deprecated

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

Deprecated: Use RunExportRequest.ProtoReflect.Descriptor instead.

func (*RunExportRequest) GetGroupId

func (x *RunExportRequest) GetGroupId() string

func (*RunExportRequest) GetParams

func (x *RunExportRequest) GetParams() *ExportParams

func (*RunExportRequest) GetResultFilename

func (x *RunExportRequest) GetResultFilename() string

func (*RunExportRequest) GetSince

func (x *RunExportRequest) GetSince() *timestamppb.Timestamp

func (*RunExportRequest) GetSinkId

func (x *RunExportRequest) GetSinkId() string

func (*RunExportRequest) GetUntil

func (x *RunExportRequest) GetUntil() *timestamppb.Timestamp

func (*RunExportRequest) ProtoMessage

func (*RunExportRequest) ProtoMessage()

func (*RunExportRequest) ProtoReflect

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

func (*RunExportRequest) Reset

func (x *RunExportRequest) Reset()

func (*RunExportRequest) SetGroupId

func (m *RunExportRequest) SetGroupId(v string)

func (*RunExportRequest) SetParams

func (m *RunExportRequest) SetParams(v *ExportParams)

func (*RunExportRequest) SetResultFilename

func (m *RunExportRequest) SetResultFilename(v string)

func (*RunExportRequest) SetSince

func (m *RunExportRequest) SetSince(v *timestamppb.Timestamp)

func (*RunExportRequest) SetSinkId

func (m *RunExportRequest) SetSinkId(v string)

func (*RunExportRequest) SetUntil

func (m *RunExportRequest) SetUntil(v *timestamppb.Timestamp)

func (*RunExportRequest) String

func (x *RunExportRequest) String() string

type Sink

type Sink struct {

	// Sink ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Sink folder ID.
	FolderId string `protobuf:"bytes,2,opt,name=folder_id,json=folderId,proto3" json:"folder_id,omitempty"`
	// Sink cloud ID.
	CloudId string `protobuf:"bytes,3,opt,name=cloud_id,json=cloudId,proto3" json:"cloud_id,omitempty"`
	// Sink creation time.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// Sink name.
	Name string `protobuf:"bytes,5,opt,name=name,proto3" json:"name,omitempty"`
	// Sink description.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Sink labels.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// Logs will be written to the sink on behalf of this service account
	ServiceAccountId string `protobuf:"bytes,8,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// Logs destination
	//
	// Types that are assignable to Sink:
	//
	//	*Sink_Yds_
	//	*Sink_S3_
	Sink isSink_Sink `protobuf_oneof:"sink"`
	// contains filtered or unexported fields
}

func (*Sink) Descriptor deprecated

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

Deprecated: Use Sink.ProtoReflect.Descriptor instead.

func (*Sink) GetCloudId

func (x *Sink) GetCloudId() string

func (*Sink) GetCreatedAt

func (x *Sink) GetCreatedAt() *timestamppb.Timestamp

func (*Sink) GetDescription

func (x *Sink) GetDescription() string

func (*Sink) GetFolderId

func (x *Sink) GetFolderId() string

func (*Sink) GetId

func (x *Sink) GetId() string

func (*Sink) GetLabels

func (x *Sink) GetLabels() map[string]string

func (*Sink) GetName

func (x *Sink) GetName() string

func (*Sink) GetS3

func (x *Sink) GetS3() *Sink_S3

func (*Sink) GetServiceAccountId

func (x *Sink) GetServiceAccountId() string

func (*Sink) GetSink

func (m *Sink) GetSink() isSink_Sink

func (*Sink) GetYds

func (x *Sink) GetYds() *Sink_Yds

func (*Sink) ProtoMessage

func (*Sink) ProtoMessage()

func (*Sink) ProtoReflect

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

func (*Sink) Reset

func (x *Sink) Reset()

func (*Sink) SetCloudId

func (m *Sink) SetCloudId(v string)

func (*Sink) SetCreatedAt

func (m *Sink) SetCreatedAt(v *timestamppb.Timestamp)

func (*Sink) SetDescription

func (m *Sink) SetDescription(v string)

func (*Sink) SetFolderId

func (m *Sink) SetFolderId(v string)

func (*Sink) SetId

func (m *Sink) SetId(v string)

func (*Sink) SetLabels

func (m *Sink) SetLabels(v map[string]string)

func (*Sink) SetName

func (m *Sink) SetName(v string)

func (*Sink) SetS3

func (m *Sink) SetS3(v *Sink_S3)

func (*Sink) SetServiceAccountId

func (m *Sink) SetServiceAccountId(v string)

func (*Sink) SetSink

func (m *Sink) SetSink(v Sink_Sink)

func (*Sink) SetYds

func (m *Sink) SetYds(v *Sink_Yds)

func (*Sink) String

func (x *Sink) String() string

type SinkServiceClient

type SinkServiceClient interface {
	// Returns the specified sink.
	//
	// To get the list of all available sinks, make a [List] request.
	Get(ctx context.Context, in *GetSinkRequest, opts ...grpc.CallOption) (*Sink, error)
	// Retrieves the list of sinks in the specified folder.
	List(ctx context.Context, in *ListSinksRequest, opts ...grpc.CallOption) (*ListSinksResponse, error)
	// Creates a sink in the specified folder.
	Create(ctx context.Context, in *CreateSinkRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates the specified sink.
	Update(ctx context.Context, in *UpdateSinkRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Deletes the specified sink.
	Delete(ctx context.Context, in *DeleteSinkRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Lists operations for the specified sink.
	ListOperations(ctx context.Context, in *ListSinkOperationsRequest, opts ...grpc.CallOption) (*ListSinkOperationsResponse, error)
	// Lists existing access bindings for the specified sink.
	ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified sink.
	SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
	// Updates access bindings for the specified sink.
	UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)
}

SinkServiceClient is the client API for SinkService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SinkServiceServer

type SinkServiceServer interface {
	// Returns the specified sink.
	//
	// To get the list of all available sinks, make a [List] request.
	Get(context.Context, *GetSinkRequest) (*Sink, error)
	// Retrieves the list of sinks in the specified folder.
	List(context.Context, *ListSinksRequest) (*ListSinksResponse, error)
	// Creates a sink in the specified folder.
	Create(context.Context, *CreateSinkRequest) (*operation.Operation, error)
	// Updates the specified sink.
	Update(context.Context, *UpdateSinkRequest) (*operation.Operation, error)
	// Deletes the specified sink.
	Delete(context.Context, *DeleteSinkRequest) (*operation.Operation, error)
	// Lists operations for the specified sink.
	ListOperations(context.Context, *ListSinkOperationsRequest) (*ListSinkOperationsResponse, error)
	// Lists existing access bindings for the specified sink.
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)
	// Sets access bindings for the specified sink.
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)
	// Updates access bindings for the specified sink.
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)
}

SinkServiceServer is the server API for SinkService service. All implementations should embed UnimplementedSinkServiceServer for forward compatibility

type Sink_S3

type Sink_S3 struct {

	// Object storage bucket
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// Prefix to use for saved log object names
	Prefix string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*Sink_S3) Descriptor deprecated

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

Deprecated: Use Sink_S3.ProtoReflect.Descriptor instead.

func (*Sink_S3) GetBucket

func (x *Sink_S3) GetBucket() string

func (*Sink_S3) GetPrefix

func (x *Sink_S3) GetPrefix() string

func (*Sink_S3) ProtoMessage

func (*Sink_S3) ProtoMessage()

func (*Sink_S3) ProtoReflect

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

func (*Sink_S3) Reset

func (x *Sink_S3) Reset()

func (*Sink_S3) SetBucket

func (m *Sink_S3) SetBucket(v string)

func (*Sink_S3) SetPrefix

func (m *Sink_S3) SetPrefix(v string)

func (*Sink_S3) String

func (x *Sink_S3) String() string

type Sink_S3_

type Sink_S3_ struct {
	// Object storage
	S3 *Sink_S3 `protobuf:"bytes,10,opt,name=s3,proto3,oneof"`
}

type Sink_Sink

type Sink_Sink = isSink_Sink

type Sink_Yds

type Sink_Yds struct {

	// Fully qualified name of data stream
	StreamName string `protobuf:"bytes,1,opt,name=stream_name,json=streamName,proto3" json:"stream_name,omitempty"`
	// contains filtered or unexported fields
}

func (*Sink_Yds) Descriptor deprecated

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

Deprecated: Use Sink_Yds.ProtoReflect.Descriptor instead.

func (*Sink_Yds) GetStreamName

func (x *Sink_Yds) GetStreamName() string

func (*Sink_Yds) ProtoMessage

func (*Sink_Yds) ProtoMessage()

func (*Sink_Yds) ProtoReflect

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

func (*Sink_Yds) Reset

func (x *Sink_Yds) Reset()

func (*Sink_Yds) SetStreamName

func (m *Sink_Yds) SetStreamName(v string)

func (*Sink_Yds) String

func (x *Sink_Yds) String() string

type Sink_Yds_

type Sink_Yds_ struct {
	// Yandex data stream
	Yds *Sink_Yds `protobuf:"bytes,9,opt,name=yds,proto3,oneof"`
}

type UnimplementedExportServiceServer

type UnimplementedExportServiceServer struct {
}

UnimplementedExportServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedExportServiceServer) Create

func (UnimplementedExportServiceServer) Delete

func (UnimplementedExportServiceServer) Get

func (UnimplementedExportServiceServer) List

func (UnimplementedExportServiceServer) Run

func (UnimplementedExportServiceServer) SetAccessBindings

func (UnimplementedExportServiceServer) Update

func (UnimplementedExportServiceServer) UpdateAccessBindings

type UnimplementedLogGroupServiceServer

type UnimplementedLogGroupServiceServer struct {
}

UnimplementedLogGroupServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLogGroupServiceServer) Create

func (UnimplementedLogGroupServiceServer) Delete

func (UnimplementedLogGroupServiceServer) Get

func (UnimplementedLogGroupServiceServer) List

func (UnimplementedLogGroupServiceServer) ListOperations

func (UnimplementedLogGroupServiceServer) ListResources

func (UnimplementedLogGroupServiceServer) SetAccessBindings

func (UnimplementedLogGroupServiceServer) Update

func (UnimplementedLogGroupServiceServer) UpdateAccessBindings

type UnimplementedLogIngestionServiceServer

type UnimplementedLogIngestionServiceServer struct {
}

UnimplementedLogIngestionServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLogIngestionServiceServer) Write

type UnimplementedLogReadingServiceServer

type UnimplementedLogReadingServiceServer struct {
}

UnimplementedLogReadingServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedLogReadingServiceServer) Read

type UnimplementedSinkServiceServer

type UnimplementedSinkServiceServer struct {
}

UnimplementedSinkServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedSinkServiceServer) Create

func (UnimplementedSinkServiceServer) Delete

func (UnimplementedSinkServiceServer) Get

func (UnimplementedSinkServiceServer) List

func (UnimplementedSinkServiceServer) SetAccessBindings

func (UnimplementedSinkServiceServer) Update

func (UnimplementedSinkServiceServer) UpdateAccessBindings

type UnsafeExportServiceServer

type UnsafeExportServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeExportServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ExportServiceServer will result in compilation errors.

type UnsafeLogGroupServiceServer

type UnsafeLogGroupServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLogGroupServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogGroupServiceServer will result in compilation errors.

type UnsafeLogIngestionServiceServer

type UnsafeLogIngestionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLogIngestionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogIngestionServiceServer will result in compilation errors.

type UnsafeLogReadingServiceServer

type UnsafeLogReadingServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLogReadingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogReadingServiceServer will result in compilation errors.

type UnsafeSinkServiceServer

type UnsafeSinkServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSinkServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SinkServiceServer will result in compilation errors.

type UpdateExportMetadata

type UpdateExportMetadata struct {

	// ID of the export being updated.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateExportMetadata) Descriptor deprecated

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

Deprecated: Use UpdateExportMetadata.ProtoReflect.Descriptor instead.

func (*UpdateExportMetadata) GetExportId

func (x *UpdateExportMetadata) GetExportId() string

func (*UpdateExportMetadata) ProtoMessage

func (*UpdateExportMetadata) ProtoMessage()

func (*UpdateExportMetadata) ProtoReflect

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

func (*UpdateExportMetadata) Reset

func (x *UpdateExportMetadata) Reset()

func (*UpdateExportMetadata) SetExportId

func (m *UpdateExportMetadata) SetExportId(v string)

func (*UpdateExportMetadata) String

func (x *UpdateExportMetadata) String() string

type UpdateExportRequest

type UpdateExportRequest struct {

	// ID of the export to update.
	//
	// To get a export ID make a [ExportService.List] request.
	ExportId string `protobuf:"bytes,1,opt,name=export_id,json=exportId,proto3" json:"export_id,omitempty"`
	// Field mask that specifies which attributes of the function should be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the export.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New Description of the export.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New export labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New logging Group ID logs exported from
	GroupId string `protobuf:"bytes,6,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	// New logging Sink ID logs exported to
	SinkId string `protobuf:"bytes,7,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// New parameters for logs filtration
	Params *ExportParams `protobuf:"bytes,8,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateExportRequest) Descriptor deprecated

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

Deprecated: Use UpdateExportRequest.ProtoReflect.Descriptor instead.

func (*UpdateExportRequest) GetDescription

func (x *UpdateExportRequest) GetDescription() string

func (*UpdateExportRequest) GetExportId

func (x *UpdateExportRequest) GetExportId() string

func (*UpdateExportRequest) GetGroupId

func (x *UpdateExportRequest) GetGroupId() string

func (*UpdateExportRequest) GetLabels

func (x *UpdateExportRequest) GetLabels() map[string]string

func (*UpdateExportRequest) GetName

func (x *UpdateExportRequest) GetName() string

func (*UpdateExportRequest) GetParams

func (x *UpdateExportRequest) GetParams() *ExportParams

func (*UpdateExportRequest) GetSinkId

func (x *UpdateExportRequest) GetSinkId() string

func (*UpdateExportRequest) GetUpdateMask

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

func (*UpdateExportRequest) ProtoMessage

func (*UpdateExportRequest) ProtoMessage()

func (*UpdateExportRequest) ProtoReflect

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

func (*UpdateExportRequest) Reset

func (x *UpdateExportRequest) Reset()

func (*UpdateExportRequest) SetDescription

func (m *UpdateExportRequest) SetDescription(v string)

func (*UpdateExportRequest) SetExportId

func (m *UpdateExportRequest) SetExportId(v string)

func (*UpdateExportRequest) SetGroupId

func (m *UpdateExportRequest) SetGroupId(v string)

func (*UpdateExportRequest) SetLabels

func (m *UpdateExportRequest) SetLabels(v map[string]string)

func (*UpdateExportRequest) SetName

func (m *UpdateExportRequest) SetName(v string)

func (*UpdateExportRequest) SetParams

func (m *UpdateExportRequest) SetParams(v *ExportParams)

func (*UpdateExportRequest) SetSinkId

func (m *UpdateExportRequest) SetSinkId(v string)

func (*UpdateExportRequest) SetUpdateMask

func (m *UpdateExportRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateExportRequest) String

func (x *UpdateExportRequest) String() string

type UpdateLogGroupMetadata

type UpdateLogGroupMetadata struct {

	// ID of the log group being updated.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLogGroupMetadata) Descriptor deprecated

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

Deprecated: Use UpdateLogGroupMetadata.ProtoReflect.Descriptor instead.

func (*UpdateLogGroupMetadata) GetLogGroupId

func (x *UpdateLogGroupMetadata) GetLogGroupId() string

func (*UpdateLogGroupMetadata) ProtoMessage

func (*UpdateLogGroupMetadata) ProtoMessage()

func (*UpdateLogGroupMetadata) ProtoReflect

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

func (*UpdateLogGroupMetadata) Reset

func (x *UpdateLogGroupMetadata) Reset()

func (*UpdateLogGroupMetadata) SetLogGroupId

func (m *UpdateLogGroupMetadata) SetLogGroupId(v string)

func (*UpdateLogGroupMetadata) String

func (x *UpdateLogGroupMetadata) String() string

type UpdateLogGroupRequest

type UpdateLogGroupRequest struct {

	// ID of the log group to update.
	//
	// To get a log group ID make a [LogGroupService.List] request.
	LogGroupId string `protobuf:"bytes,1,opt,name=log_group_id,json=logGroupId,proto3" json:"log_group_id,omitempty"`
	// Field mask that specifies which attributes of the function should be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the log group.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New Description of the log group.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New log group labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// New log group entry retention period.
	//
	// Entries will be present in group during this period.
	// If specified, must be non-negative.
	// Empty or zero value is treated as no limit.
	RetentionPeriod *durationpb.Duration `protobuf:"bytes,6,opt,name=retention_period,json=retentionPeriod,proto3" json:"retention_period,omitempty"`
	// If specified, log records will be written to this data stream
	DataStream string `protobuf:"bytes,7,opt,name=data_stream,json=dataStream,proto3" json:"data_stream,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLogGroupRequest) Descriptor deprecated

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

Deprecated: Use UpdateLogGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateLogGroupRequest) GetDataStream

func (x *UpdateLogGroupRequest) GetDataStream() string

func (*UpdateLogGroupRequest) GetDescription

func (x *UpdateLogGroupRequest) GetDescription() string

func (*UpdateLogGroupRequest) GetLabels

func (x *UpdateLogGroupRequest) GetLabels() map[string]string

func (*UpdateLogGroupRequest) GetLogGroupId

func (x *UpdateLogGroupRequest) GetLogGroupId() string

func (*UpdateLogGroupRequest) GetName

func (x *UpdateLogGroupRequest) GetName() string

func (*UpdateLogGroupRequest) GetRetentionPeriod

func (x *UpdateLogGroupRequest) GetRetentionPeriod() *durationpb.Duration

func (*UpdateLogGroupRequest) GetUpdateMask

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

func (*UpdateLogGroupRequest) ProtoMessage

func (*UpdateLogGroupRequest) ProtoMessage()

func (*UpdateLogGroupRequest) ProtoReflect

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

func (*UpdateLogGroupRequest) Reset

func (x *UpdateLogGroupRequest) Reset()

func (*UpdateLogGroupRequest) SetDataStream

func (m *UpdateLogGroupRequest) SetDataStream(v string)

func (*UpdateLogGroupRequest) SetDescription

func (m *UpdateLogGroupRequest) SetDescription(v string)

func (*UpdateLogGroupRequest) SetLabels

func (m *UpdateLogGroupRequest) SetLabels(v map[string]string)

func (*UpdateLogGroupRequest) SetLogGroupId

func (m *UpdateLogGroupRequest) SetLogGroupId(v string)

func (*UpdateLogGroupRequest) SetName

func (m *UpdateLogGroupRequest) SetName(v string)

func (*UpdateLogGroupRequest) SetRetentionPeriod

func (m *UpdateLogGroupRequest) SetRetentionPeriod(v *durationpb.Duration)

func (*UpdateLogGroupRequest) SetUpdateMask

func (m *UpdateLogGroupRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateLogGroupRequest) String

func (x *UpdateLogGroupRequest) String() string

type UpdateSinkMetadata

type UpdateSinkMetadata struct {

	// ID of the sink being updated.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSinkMetadata) Descriptor deprecated

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

Deprecated: Use UpdateSinkMetadata.ProtoReflect.Descriptor instead.

func (*UpdateSinkMetadata) GetSinkId

func (x *UpdateSinkMetadata) GetSinkId() string

func (*UpdateSinkMetadata) ProtoMessage

func (*UpdateSinkMetadata) ProtoMessage()

func (*UpdateSinkMetadata) ProtoReflect

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

func (*UpdateSinkMetadata) Reset

func (x *UpdateSinkMetadata) Reset()

func (*UpdateSinkMetadata) SetSinkId

func (m *UpdateSinkMetadata) SetSinkId(v string)

func (*UpdateSinkMetadata) String

func (x *UpdateSinkMetadata) String() string

type UpdateSinkRequest

type UpdateSinkRequest struct {

	// ID of the sink to update.
	//
	// To get a sink ID make a [SinkService.List] request.
	SinkId string `protobuf:"bytes,1,opt,name=sink_id,json=sinkId,proto3" json:"sink_id,omitempty"`
	// Field mask that specifies which attributes of the function should be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// New name of the sink.
	// The name must be unique within the folder.
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// New Description of the sink.
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// New sink labels as `key:value` pairs.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// new service account to use for logs writing to the sink.
	ServiceAccountId string `protobuf:"bytes,6,opt,name=service_account_id,json=serviceAccountId,proto3" json:"service_account_id,omitempty"`
	// New logs destination
	//
	// Types that are assignable to Sink:
	//
	//	*UpdateSinkRequest_Yds
	//	*UpdateSinkRequest_S3
	Sink isUpdateSinkRequest_Sink `protobuf_oneof:"sink"`
	// contains filtered or unexported fields
}

func (*UpdateSinkRequest) Descriptor deprecated

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

Deprecated: Use UpdateSinkRequest.ProtoReflect.Descriptor instead.

func (*UpdateSinkRequest) GetDescription

func (x *UpdateSinkRequest) GetDescription() string

func (*UpdateSinkRequest) GetLabels

func (x *UpdateSinkRequest) GetLabels() map[string]string

func (*UpdateSinkRequest) GetName

func (x *UpdateSinkRequest) GetName() string

func (*UpdateSinkRequest) GetS3

func (x *UpdateSinkRequest) GetS3() *Sink_S3

func (*UpdateSinkRequest) GetServiceAccountId

func (x *UpdateSinkRequest) GetServiceAccountId() string

func (*UpdateSinkRequest) GetSink

func (m *UpdateSinkRequest) GetSink() isUpdateSinkRequest_Sink

func (*UpdateSinkRequest) GetSinkId

func (x *UpdateSinkRequest) GetSinkId() string

func (*UpdateSinkRequest) GetUpdateMask

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

func (*UpdateSinkRequest) GetYds

func (x *UpdateSinkRequest) GetYds() *Sink_Yds

func (*UpdateSinkRequest) ProtoMessage

func (*UpdateSinkRequest) ProtoMessage()

func (*UpdateSinkRequest) ProtoReflect

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

func (*UpdateSinkRequest) Reset

func (x *UpdateSinkRequest) Reset()

func (*UpdateSinkRequest) SetDescription

func (m *UpdateSinkRequest) SetDescription(v string)

func (*UpdateSinkRequest) SetLabels

func (m *UpdateSinkRequest) SetLabels(v map[string]string)

func (*UpdateSinkRequest) SetName

func (m *UpdateSinkRequest) SetName(v string)

func (*UpdateSinkRequest) SetS3

func (m *UpdateSinkRequest) SetS3(v *Sink_S3)

func (*UpdateSinkRequest) SetServiceAccountId

func (m *UpdateSinkRequest) SetServiceAccountId(v string)

func (*UpdateSinkRequest) SetSink

func (*UpdateSinkRequest) SetSinkId

func (m *UpdateSinkRequest) SetSinkId(v string)

func (*UpdateSinkRequest) SetUpdateMask

func (m *UpdateSinkRequest) SetUpdateMask(v *fieldmaskpb.FieldMask)

func (*UpdateSinkRequest) SetYds

func (m *UpdateSinkRequest) SetYds(v *Sink_Yds)

func (*UpdateSinkRequest) String

func (x *UpdateSinkRequest) String() string

type UpdateSinkRequest_S3

type UpdateSinkRequest_S3 struct {
	// Object storage
	S3 *Sink_S3 `protobuf:"bytes,8,opt,name=s3,proto3,oneof"`
}

type UpdateSinkRequest_Sink

type UpdateSinkRequest_Sink = isUpdateSinkRequest_Sink

type UpdateSinkRequest_Yds

type UpdateSinkRequest_Yds struct {
	// Yandex data stream
	Yds *Sink_Yds `protobuf:"bytes,7,opt,name=yds,proto3,oneof"`
}

type WriteRequest

type WriteRequest struct {

	// Log entries destination.
	//
	// See [Destination] for details.
	Destination *Destination `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	// Common resource (type, ID) specification for log entries.
	Resource *LogEntryResource `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	// List of log entries.
	Entries []*IncomingLogEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// Log entries defaults.
	//
	// See [LogEntryDefaults] for details.
	Defaults *LogEntryDefaults `protobuf:"bytes,4,opt,name=defaults,proto3" json:"defaults,omitempty"`
	// contains filtered or unexported fields
}

func (*WriteRequest) Descriptor deprecated

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

Deprecated: Use WriteRequest.ProtoReflect.Descriptor instead.

func (*WriteRequest) GetDefaults

func (x *WriteRequest) GetDefaults() *LogEntryDefaults

func (*WriteRequest) GetDestination

func (x *WriteRequest) GetDestination() *Destination

func (*WriteRequest) GetEntries

func (x *WriteRequest) GetEntries() []*IncomingLogEntry

func (*WriteRequest) GetResource

func (x *WriteRequest) GetResource() *LogEntryResource

func (*WriteRequest) ProtoMessage

func (*WriteRequest) ProtoMessage()

func (*WriteRequest) ProtoReflect

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

func (*WriteRequest) Reset

func (x *WriteRequest) Reset()

func (*WriteRequest) SetDefaults

func (m *WriteRequest) SetDefaults(v *LogEntryDefaults)

func (*WriteRequest) SetDestination

func (m *WriteRequest) SetDestination(v *Destination)

func (*WriteRequest) SetEntries

func (m *WriteRequest) SetEntries(v []*IncomingLogEntry)

func (*WriteRequest) SetResource

func (m *WriteRequest) SetResource(v *LogEntryResource)

func (*WriteRequest) String

func (x *WriteRequest) String() string

type WriteResponse

type WriteResponse struct {

	// Map<idx, status> of ingest failures.
	//
	// If entry with idx N is absent, it was ingested successfully.
	Errors map[int64]*status.Status `` /* 154-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WriteResponse) Descriptor deprecated

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

Deprecated: Use WriteResponse.ProtoReflect.Descriptor instead.

func (*WriteResponse) GetErrors

func (x *WriteResponse) GetErrors() map[int64]*status.Status

func (*WriteResponse) ProtoMessage

func (*WriteResponse) ProtoMessage()

func (*WriteResponse) ProtoReflect

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

func (*WriteResponse) Reset

func (x *WriteResponse) Reset()

func (*WriteResponse) SetErrors

func (m *WriteResponse) SetErrors(v map[int64]*status.Status)

func (*WriteResponse) String

func (x *WriteResponse) String() string

Jump to

Keyboard shortcuts

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