logging

package
v0.0.0-...-f84a9a7 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: MIT Imports: 18 Imported by: 10

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 (m *CreateSinkRequest) SetSink(v CreateSinkRequest_Sink)

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.

A set of methods for managing log exports.

func NewExportServiceClient 

func NewExportServiceClient(cc grpc.ClientConnInterface) ExportServiceClient

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.

A set of methods for managing log exports.

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 (x *ListExportOperationsRequest) ProtoReflect() protoreflect.Message

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 (x *ListExportOperationsResponse) ProtoReflect() protoreflect.Message

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 

func (x *ListExportOperationsResponse) String() 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 (x *ListSinkOperationsRequest) ProtoReflect() protoreflect.Message

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 (x *ListSinkOperationsResponse) ProtoReflect() protoreflect.Message

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.

A set of methods for managing log groups.

func NewLogGroupServiceClient 

func NewLogGroupServiceClient(cc grpc.ClientConnInterface) LogGroupServiceClient

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.

A set of methods for managing log groups.

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) Descriptor() protoreflect.EnumDescriptor

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 (x LogGroup_Status) Number() protoreflect.EnumNumber

func (LogGroup_Status) String 

func (x LogGroup_Status) String() string

func (LogGroup_Status) Type 

func (LogGroup_Status) Type() protoreflect.EnumType

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.

A set of methods for writing to log groups.

func NewLogIngestionServiceClient 

func NewLogIngestionServiceClient(cc grpc.ClientConnInterface) LogIngestionServiceClient

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.

A set of methods for writing to log groups.

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) Descriptor() protoreflect.EnumDescriptor

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 (x LogLevel_Level) Number() protoreflect.EnumNumber

func (LogLevel_Level) String 

func (x LogLevel_Level) String() string

func (LogLevel_Level) Type 

func (LogLevel_Level) Type() protoreflect.EnumType

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.

A set of methods for reading from log groups.

func NewLogReadingServiceClient 

func NewLogReadingServiceClient(cc grpc.ClientConnInterface) LogReadingServiceClient

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.

A set of methods for reading from log groups.

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.

A set of methods for managing log sinks.

func NewSinkServiceClient 

func NewSinkServiceClient(cc grpc.ClientConnInterface) SinkServiceClient

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.

A set of methods for managing log sinks.

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.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedExportServiceServer) Create 

func (UnimplementedExportServiceServer) Create(context.Context, *CreateExportRequest) (*operation.Operation, error)

func (UnimplementedExportServiceServer) Delete 

func (UnimplementedExportServiceServer) Delete(context.Context, *DeleteExportRequest) (*operation.Operation, error)

func (UnimplementedExportServiceServer) Get 

func (UnimplementedExportServiceServer) Get(context.Context, *GetExportRequest) (*Export, error)

func (UnimplementedExportServiceServer) List 

func (UnimplementedExportServiceServer) List(context.Context, *ListExportsRequest) (*ListExportsResponse, error)

func (UnimplementedExportServiceServer) ListAccessBindings 

func (UnimplementedExportServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedExportServiceServer) ListOperations 

func (UnimplementedExportServiceServer) ListOperations(context.Context, *ListExportOperationsRequest) (*ListExportOperationsResponse, error)

func (UnimplementedExportServiceServer) Run 

func (UnimplementedExportServiceServer) Run(context.Context, *RunExportRequest) (*operation.Operation, error)

func (UnimplementedExportServiceServer) SetAccessBindings 

func (UnimplementedExportServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedExportServiceServer) Update 

func (UnimplementedExportServiceServer) Update(context.Context, *UpdateExportRequest) (*operation.Operation, error)

func (UnimplementedExportServiceServer) UpdateAccessBindings 

func (UnimplementedExportServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

type UnimplementedLogGroupServiceServer 

type UnimplementedLogGroupServiceServer struct{}

UnimplementedLogGroupServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLogGroupServiceServer) Create 

func (UnimplementedLogGroupServiceServer) Create(context.Context, *CreateLogGroupRequest) (*operation.Operation, error)

func (UnimplementedLogGroupServiceServer) Delete 

func (UnimplementedLogGroupServiceServer) Delete(context.Context, *DeleteLogGroupRequest) (*operation.Operation, error)

func (UnimplementedLogGroupServiceServer) Get 

func (UnimplementedLogGroupServiceServer) Get(context.Context, *GetLogGroupRequest) (*LogGroup, error)

func (UnimplementedLogGroupServiceServer) List 

func (UnimplementedLogGroupServiceServer) List(context.Context, *ListLogGroupsRequest) (*ListLogGroupsResponse, error)

func (UnimplementedLogGroupServiceServer) ListAccessBindings 

func (UnimplementedLogGroupServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedLogGroupServiceServer) ListOperations 

func (UnimplementedLogGroupServiceServer) ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)

func (UnimplementedLogGroupServiceServer) ListResources 

func (UnimplementedLogGroupServiceServer) ListResources(context.Context, *ListResourcesRequest) (*ListResourcesResponse, error)

func (UnimplementedLogGroupServiceServer) SetAccessBindings 

func (UnimplementedLogGroupServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedLogGroupServiceServer) Stats 

func (UnimplementedLogGroupServiceServer) Stats(context.Context, *GetLogGroupStatsRequest) (*GetLogGroupStatsResponse, error)

func (UnimplementedLogGroupServiceServer) Update 

func (UnimplementedLogGroupServiceServer) Update(context.Context, *UpdateLogGroupRequest) (*operation.Operation, error)

func (UnimplementedLogGroupServiceServer) UpdateAccessBindings 

func (UnimplementedLogGroupServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

type UnimplementedLogIngestionServiceServer 

type UnimplementedLogIngestionServiceServer struct{}

UnimplementedLogIngestionServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLogIngestionServiceServer) Write 

func (UnimplementedLogIngestionServiceServer) Write(context.Context, *WriteRequest) (*WriteResponse, error)

type UnimplementedLogReadingServiceServer 

type UnimplementedLogReadingServiceServer struct{}

UnimplementedLogReadingServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLogReadingServiceServer) Read 

func (UnimplementedLogReadingServiceServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)

type UnimplementedSinkServiceServer 

type UnimplementedSinkServiceServer struct{}

UnimplementedSinkServiceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSinkServiceServer) Create 

func (UnimplementedSinkServiceServer) Create(context.Context, *CreateSinkRequest) (*operation.Operation, error)

func (UnimplementedSinkServiceServer) Delete 

func (UnimplementedSinkServiceServer) Delete(context.Context, *DeleteSinkRequest) (*operation.Operation, error)

func (UnimplementedSinkServiceServer) Get 

func (UnimplementedSinkServiceServer) Get(context.Context, *GetSinkRequest) (*Sink, error)

func (UnimplementedSinkServiceServer) List 

func (UnimplementedSinkServiceServer) List(context.Context, *ListSinksRequest) (*ListSinksResponse, error)

func (UnimplementedSinkServiceServer) ListAccessBindings 

func (UnimplementedSinkServiceServer) ListAccessBindings(context.Context, *access.ListAccessBindingsRequest) (*access.ListAccessBindingsResponse, error)

func (UnimplementedSinkServiceServer) ListOperations 

func (UnimplementedSinkServiceServer) ListOperations(context.Context, *ListSinkOperationsRequest) (*ListSinkOperationsResponse, error)

func (UnimplementedSinkServiceServer) SetAccessBindings 

func (UnimplementedSinkServiceServer) SetAccessBindings(context.Context, *access.SetAccessBindingsRequest) (*operation.Operation, error)

func (UnimplementedSinkServiceServer) Update 

func (UnimplementedSinkServiceServer) Update(context.Context, *UpdateSinkRequest) (*operation.Operation, error)

func (UnimplementedSinkServiceServer) UpdateAccessBindings 

func (UnimplementedSinkServiceServer) UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest) (*operation.Operation, error)

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 (m *UpdateSinkRequest) SetSink(v UpdateSinkRequest_Sink)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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