loggingsdk

package
v0.0.79 Latest Latest
Warning

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

 Go to latest Published: Jul 20, 2026 License: MIT Imports: 12 Imported by: 1

Documentation

Overview

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Code generated by sdkgen-v2. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExportGet                  = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.Get")
	ExportList                 = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.List")
	ExportCreate               = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.Create")
	ExportUpdate               = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.Update")
	ExportDelete               = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.Delete")
	ExportRun                  = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.Run")
	ExportListOperations       = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.ListOperations")
	ExportListAccessBindings   = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.ListAccessBindings")
	ExportSetAccessBindings    = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.SetAccessBindings")
	ExportUpdateAccessBindings = protoreflect.FullName("yandex.cloud.logging.v1.ExportService.UpdateAccessBindings")
	ExportOperationPoller      = protoreflect.FullName("yandex.cloud.operation.OperationService.Get")
)
View Source 
var (
	LogGroupGet                  = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.Get")
	LogGroupStats                = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.Stats")
	LogGroupList                 = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.List")
	LogGroupCreate               = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.Create")
	LogGroupUpdate               = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.Update")
	LogGroupDelete               = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.Delete")
	LogGroupListResources        = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.ListResources")
	LogGroupListOperations       = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.ListOperations")
	LogGroupListAccessBindings   = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.ListAccessBindings")
	LogGroupSetAccessBindings    = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.SetAccessBindings")
	LogGroupUpdateAccessBindings = protoreflect.FullName("yandex.cloud.logging.v1.LogGroupService.UpdateAccessBindings")
	LogGroupOperationPoller      = protoreflect.FullName("yandex.cloud.operation.OperationService.Get")
)
View Source 
var (
	SinkGet                  = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.Get")
	SinkList                 = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.List")
	SinkCreate               = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.Create")
	SinkUpdate               = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.Update")
	SinkDelete               = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.Delete")
	SinkListOperations       = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.ListOperations")
	SinkListAccessBindings   = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.ListAccessBindings")
	SinkSetAccessBindings    = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.SetAccessBindings")
	SinkUpdateAccessBindings = protoreflect.FullName("yandex.cloud.logging.v1.SinkService.UpdateAccessBindings")
	SinkOperationPoller      = protoreflect.FullName("yandex.cloud.operation.OperationService.Get")
)
View Source 
var (
	LogIngestionWrite = protoreflect.FullName("yandex.cloud.logging.v1.LogIngestionService.Write")
)
View Source 
var (
	LogReadingRead = protoreflect.FullName("yandex.cloud.logging.v1.LogReadingService.Read")
)

Functions

func ExportResolver added in v0.0.30 

func ExportResolver(name string, client ExportClient, opts ...sdkresolvers.ResolveOption) sdkresolvers.Resolver

func LogGroupResolver added in v0.0.30 

func LogGroupResolver(name string, client LogGroupClient, opts ...sdkresolvers.ResolveOption) sdkresolvers.Resolver

func SinkResolver added in v0.0.30 

func SinkResolver(name string, client SinkClient, opts ...sdkresolvers.ResolveOption) sdkresolvers.Resolver

Types

type ExportClient 

type ExportClient interface {
	ExportClientIterator
	Get(context.Context, *logging.GetExportRequest, ...grpc.CallOption) (*logging.Export, error)
	List(context.Context, *logging.ListExportsRequest, ...grpc.CallOption) (*logging.ListExportsResponse, error)
	Create(context.Context, *logging.CreateExportRequest, ...grpc.CallOption) (*ExportCreateOperation, error)
	Update(context.Context, *logging.UpdateExportRequest, ...grpc.CallOption) (*ExportUpdateOperation, error)
	Delete(context.Context, *logging.DeleteExportRequest, ...grpc.CallOption) (*ExportDeleteOperation, error)
	Run(context.Context, *logging.RunExportRequest, ...grpc.CallOption) (*ExportRunOperation, error)
	ListOperations(context.Context, *logging.ListExportOperationsRequest, ...grpc.CallOption) (*logging.ListExportOperationsResponse, error)
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest, ...grpc.CallOption) (*ExportSetAccessBindingsOperation, error)
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest, ...grpc.CallOption) (*ExportUpdateAccessBindingsOperation, error)
}

ExportClient provides methods for managing Export resources of Yandex.Cloud Logging.

func NewExportClient 

func NewExportClient(connector transport.Connector) ExportClient

NewExportClient returns ExportClient implementation.

type ExportClientIterator added in v0.0.26 

type ExportClientIterator interface {
	Iterator(context.Context, *logging.ListExportsRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListExportsRequest, *logging.Export]
	OperationsIterator(context.Context, *logging.ListExportOperationsRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListExportOperationsRequest, *operation.Operation]
	AccessBindingsIterator(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) *iterator.Iterator[*access.ListAccessBindingsRequest, *access.AccessBinding]
}

type ExportCreateOperation 

type ExportCreateOperation struct {
	sdkop.Operation
}

ExportCreateOperation is used to monitor the state of Create operations.

func (*ExportCreateOperation) Metadata 

func (o *ExportCreateOperation) Metadata() *logging.CreateExportMetadata

Metadata retrieves the operation metadata.

func (*ExportCreateOperation) Response 

func (o *ExportCreateOperation) Response() *logging.Export

Response retrieves the operation response.

func (*ExportCreateOperation) Wait 

func (o *ExportCreateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.Export, error)

Wait polls the operation until it's done.

func (*ExportCreateOperation) WaitInterval 

func (o *ExportCreateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.Export, error)

WaitInterval polls the operation until it's done with custom interval.

type ExportDeleteOperation 

type ExportDeleteOperation struct {
	sdkop.Operation
}

ExportDeleteOperation is used to monitor the state of Delete operations.

func (*ExportDeleteOperation) Metadata 

func (o *ExportDeleteOperation) Metadata() *logging.DeleteExportMetadata

Metadata retrieves the operation metadata.

func (*ExportDeleteOperation) Response 

func (o *ExportDeleteOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*ExportDeleteOperation) Wait 

func (o *ExportDeleteOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*ExportDeleteOperation) WaitInterval 

func (o *ExportDeleteOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type ExportRunOperation 

type ExportRunOperation struct {
	sdkop.Operation
}

ExportRunOperation is used to monitor the state of Run operations.

func (*ExportRunOperation) Metadata 

func (o *ExportRunOperation) Metadata() *logging.RunExportMetadata

Metadata retrieves the operation metadata.

func (*ExportRunOperation) Response 

func (o *ExportRunOperation) Response() *logging.RunExportDetails

Response retrieves the operation response.

func (*ExportRunOperation) Wait 

func (o *ExportRunOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.RunExportDetails, error)

Wait polls the operation until it's done.

func (*ExportRunOperation) WaitInterval 

func (o *ExportRunOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.RunExportDetails, error)

WaitInterval polls the operation until it's done with custom interval.

type ExportSetAccessBindingsOperation 

type ExportSetAccessBindingsOperation struct {
	sdkop.Operation
}

ExportSetAccessBindingsOperation is used to monitor the state of SetAccessBindings operations.

func (*ExportSetAccessBindingsOperation) Metadata added in v0.0.10 

func (o *ExportSetAccessBindingsOperation) Metadata() *access.SetAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*ExportSetAccessBindingsOperation) Response 

func (o *ExportSetAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*ExportSetAccessBindingsOperation) Wait 

func (o *ExportSetAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*ExportSetAccessBindingsOperation) WaitInterval 

func (o *ExportSetAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type ExportUpdateAccessBindingsOperation 

type ExportUpdateAccessBindingsOperation struct {
	sdkop.Operation
}

ExportUpdateAccessBindingsOperation is used to monitor the state of UpdateAccessBindings operations.

func (*ExportUpdateAccessBindingsOperation) Metadata added in v0.0.10 

func (o *ExportUpdateAccessBindingsOperation) Metadata() *access.UpdateAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*ExportUpdateAccessBindingsOperation) Response 

func (o *ExportUpdateAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*ExportUpdateAccessBindingsOperation) Wait 

func (o *ExportUpdateAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*ExportUpdateAccessBindingsOperation) WaitInterval 

func (o *ExportUpdateAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type ExportUpdateOperation 

type ExportUpdateOperation struct {
	sdkop.Operation
}

ExportUpdateOperation is used to monitor the state of Update operations.

func (*ExportUpdateOperation) Metadata 

func (o *ExportUpdateOperation) Metadata() *logging.UpdateExportMetadata

Metadata retrieves the operation metadata.

func (*ExportUpdateOperation) Response 

func (o *ExportUpdateOperation) Response() *logging.Export

Response retrieves the operation response.

func (*ExportUpdateOperation) Wait 

func (o *ExportUpdateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.Export, error)

Wait polls the operation until it's done.

func (*ExportUpdateOperation) WaitInterval 

func (o *ExportUpdateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.Export, error)

WaitInterval polls the operation until it's done with custom interval.

type LogGroupClient 

type LogGroupClient interface {
	LogGroupClientIterator
	Get(context.Context, *logging.GetLogGroupRequest, ...grpc.CallOption) (*logging.LogGroup, error)
	Stats(context.Context, *logging.GetLogGroupStatsRequest, ...grpc.CallOption) (*logging.GetLogGroupStatsResponse, error)
	List(context.Context, *logging.ListLogGroupsRequest, ...grpc.CallOption) (*logging.ListLogGroupsResponse, error)
	Create(context.Context, *logging.CreateLogGroupRequest, ...grpc.CallOption) (*LogGroupCreateOperation, error)
	Update(context.Context, *logging.UpdateLogGroupRequest, ...grpc.CallOption) (*LogGroupUpdateOperation, error)
	Delete(context.Context, *logging.DeleteLogGroupRequest, ...grpc.CallOption) (*LogGroupDeleteOperation, error)
	ListResources(context.Context, *logging.ListResourcesRequest, ...grpc.CallOption) (*logging.ListResourcesResponse, error)
	ListOperations(context.Context, *logging.ListOperationsRequest, ...grpc.CallOption) (*logging.ListOperationsResponse, error)
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest, ...grpc.CallOption) (*LogGroupSetAccessBindingsOperation, error)
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest, ...grpc.CallOption) (*LogGroupUpdateAccessBindingsOperation, error)
}

LogGroupClient provides methods for managing LogGroup resources of Yandex.Cloud Logging.

func NewLogGroupClient 

func NewLogGroupClient(connector transport.Connector) LogGroupClient

NewLogGroupClient returns LogGroupClient implementation.

type LogGroupClientIterator added in v0.0.26 

type LogGroupClientIterator interface {
	Iterator(context.Context, *logging.ListLogGroupsRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListLogGroupsRequest, *logging.LogGroup]
	ResourcesIterator(context.Context, *logging.ListResourcesRequest, ...grpc.CallOption) *iterator.SimpleIterator[*logging.ListResourcesRequest, *logging.LogGroupResource]
	OperationsIterator(context.Context, *logging.ListOperationsRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListOperationsRequest, *operation.Operation]
	AccessBindingsIterator(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) *iterator.Iterator[*access.ListAccessBindingsRequest, *access.AccessBinding]
}

type LogGroupCreateOperation 

type LogGroupCreateOperation struct {
	sdkop.Operation
}

LogGroupCreateOperation is used to monitor the state of Create operations.

func (*LogGroupCreateOperation) Metadata 

func (o *LogGroupCreateOperation) Metadata() *logging.CreateLogGroupMetadata

Metadata retrieves the operation metadata.

func (*LogGroupCreateOperation) Response 

func (o *LogGroupCreateOperation) Response() *logging.LogGroup

Response retrieves the operation response.

func (*LogGroupCreateOperation) Wait 

func (o *LogGroupCreateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.LogGroup, error)

Wait polls the operation until it's done.

func (*LogGroupCreateOperation) WaitInterval 

func (o *LogGroupCreateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.LogGroup, error)

WaitInterval polls the operation until it's done with custom interval.

type LogGroupDeleteOperation 

type LogGroupDeleteOperation struct {
	sdkop.Operation
}

LogGroupDeleteOperation is used to monitor the state of Delete operations.

func (*LogGroupDeleteOperation) Metadata 

func (o *LogGroupDeleteOperation) Metadata() *logging.DeleteLogGroupMetadata

Metadata retrieves the operation metadata.

func (*LogGroupDeleteOperation) Response 

func (o *LogGroupDeleteOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*LogGroupDeleteOperation) Wait 

func (o *LogGroupDeleteOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*LogGroupDeleteOperation) WaitInterval 

func (o *LogGroupDeleteOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type LogGroupSetAccessBindingsOperation 

type LogGroupSetAccessBindingsOperation struct {
	sdkop.Operation
}

LogGroupSetAccessBindingsOperation is used to monitor the state of SetAccessBindings operations.

func (*LogGroupSetAccessBindingsOperation) Metadata added in v0.0.10 

func (o *LogGroupSetAccessBindingsOperation) Metadata() *access.SetAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*LogGroupSetAccessBindingsOperation) Response 

func (o *LogGroupSetAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*LogGroupSetAccessBindingsOperation) Wait 

func (o *LogGroupSetAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*LogGroupSetAccessBindingsOperation) WaitInterval 

func (o *LogGroupSetAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type LogGroupUpdateAccessBindingsOperation 

type LogGroupUpdateAccessBindingsOperation struct {
	sdkop.Operation
}

LogGroupUpdateAccessBindingsOperation is used to monitor the state of UpdateAccessBindings operations.

func (*LogGroupUpdateAccessBindingsOperation) Metadata added in v0.0.10 

func (o *LogGroupUpdateAccessBindingsOperation) Metadata() *access.UpdateAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*LogGroupUpdateAccessBindingsOperation) Response 

func (o *LogGroupUpdateAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*LogGroupUpdateAccessBindingsOperation) Wait 

func (o *LogGroupUpdateAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*LogGroupUpdateAccessBindingsOperation) WaitInterval 

func (o *LogGroupUpdateAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type LogGroupUpdateOperation 

type LogGroupUpdateOperation struct {
	sdkop.Operation
}

LogGroupUpdateOperation is used to monitor the state of Update operations.

func (*LogGroupUpdateOperation) Metadata 

func (o *LogGroupUpdateOperation) Metadata() *logging.UpdateLogGroupMetadata

Metadata retrieves the operation metadata.

func (*LogGroupUpdateOperation) Response 

func (o *LogGroupUpdateOperation) Response() *logging.LogGroup

Response retrieves the operation response.

func (*LogGroupUpdateOperation) Wait 

func (o *LogGroupUpdateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.LogGroup, error)

Wait polls the operation until it's done.

func (*LogGroupUpdateOperation) WaitInterval 

func (o *LogGroupUpdateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.LogGroup, error)

WaitInterval polls the operation until it's done with custom interval.

type LogIngestionClient 

type LogIngestionClient interface {
	LogIngestionClientIterator
	Write(context.Context, *logging.WriteRequest, ...grpc.CallOption) (*logging.WriteResponse, error)
}

LogIngestionClient provides methods for managing LogIngestion resources of Yandex.Cloud Logging.

func NewLogIngestionClient 

func NewLogIngestionClient(connector transport.Connector) LogIngestionClient

NewLogIngestionClient returns LogIngestionClient implementation.

type LogIngestionClientIterator added in v0.0.26 

type LogIngestionClientIterator interface {
}

type LogReadingClient 

type LogReadingClient interface {
	LogReadingClientIterator
	Read(context.Context, *logging.ReadRequest, ...grpc.CallOption) (*logging.ReadResponse, error)
}

LogReadingClient provides methods for managing LogReading resources of Yandex.Cloud Logging.

func NewLogReadingClient 

func NewLogReadingClient(connector transport.Connector) LogReadingClient

NewLogReadingClient returns LogReadingClient implementation.

type LogReadingClientIterator added in v0.0.26 

type LogReadingClientIterator interface {
}

type SinkClient 

type SinkClient interface {
	SinkClientIterator
	Get(context.Context, *logging.GetSinkRequest, ...grpc.CallOption) (*logging.Sink, error)
	List(context.Context, *logging.ListSinksRequest, ...grpc.CallOption) (*logging.ListSinksResponse, error)
	Create(context.Context, *logging.CreateSinkRequest, ...grpc.CallOption) (*SinkCreateOperation, error)
	Update(context.Context, *logging.UpdateSinkRequest, ...grpc.CallOption) (*SinkUpdateOperation, error)
	Delete(context.Context, *logging.DeleteSinkRequest, ...grpc.CallOption) (*SinkDeleteOperation, error)
	ListOperations(context.Context, *logging.ListSinkOperationsRequest, ...grpc.CallOption) (*logging.ListSinkOperationsResponse, error)
	ListAccessBindings(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)
	SetAccessBindings(context.Context, *access.SetAccessBindingsRequest, ...grpc.CallOption) (*SinkSetAccessBindingsOperation, error)
	UpdateAccessBindings(context.Context, *access.UpdateAccessBindingsRequest, ...grpc.CallOption) (*SinkUpdateAccessBindingsOperation, error)
}

SinkClient provides methods for managing Sink resources of Yandex.Cloud Logging.

func NewSinkClient 

func NewSinkClient(connector transport.Connector) SinkClient

NewSinkClient returns SinkClient implementation.

type SinkClientIterator added in v0.0.26 

type SinkClientIterator interface {
	Iterator(context.Context, *logging.ListSinksRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListSinksRequest, *logging.Sink]
	OperationsIterator(context.Context, *logging.ListSinkOperationsRequest, ...grpc.CallOption) *iterator.Iterator[*logging.ListSinkOperationsRequest, *operation.Operation]
	AccessBindingsIterator(context.Context, *access.ListAccessBindingsRequest, ...grpc.CallOption) *iterator.Iterator[*access.ListAccessBindingsRequest, *access.AccessBinding]
}

type SinkCreateOperation 

type SinkCreateOperation struct {
	sdkop.Operation
}

SinkCreateOperation is used to monitor the state of Create operations.

func (*SinkCreateOperation) Metadata 

func (o *SinkCreateOperation) Metadata() *logging.CreateSinkMetadata

Metadata retrieves the operation metadata.

func (*SinkCreateOperation) Response 

func (o *SinkCreateOperation) Response() *logging.Sink

Response retrieves the operation response.

func (*SinkCreateOperation) Wait 

func (o *SinkCreateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.Sink, error)

Wait polls the operation until it's done.

func (*SinkCreateOperation) WaitInterval 

func (o *SinkCreateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.Sink, error)

WaitInterval polls the operation until it's done with custom interval.

type SinkDeleteOperation 

type SinkDeleteOperation struct {
	sdkop.Operation
}

SinkDeleteOperation is used to monitor the state of Delete operations.

func (*SinkDeleteOperation) Metadata 

func (o *SinkDeleteOperation) Metadata() *logging.DeleteSinkMetadata

Metadata retrieves the operation metadata.

func (*SinkDeleteOperation) Response 

func (o *SinkDeleteOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*SinkDeleteOperation) Wait 

func (o *SinkDeleteOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*SinkDeleteOperation) WaitInterval 

func (o *SinkDeleteOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type SinkSetAccessBindingsOperation 

type SinkSetAccessBindingsOperation struct {
	sdkop.Operation
}

SinkSetAccessBindingsOperation is used to monitor the state of SetAccessBindings operations.

func (*SinkSetAccessBindingsOperation) Metadata added in v0.0.10 

func (o *SinkSetAccessBindingsOperation) Metadata() *access.SetAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*SinkSetAccessBindingsOperation) Response 

func (o *SinkSetAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*SinkSetAccessBindingsOperation) Wait 

func (o *SinkSetAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*SinkSetAccessBindingsOperation) WaitInterval 

func (o *SinkSetAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type SinkUpdateAccessBindingsOperation 

type SinkUpdateAccessBindingsOperation struct {
	sdkop.Operation
}

SinkUpdateAccessBindingsOperation is used to monitor the state of UpdateAccessBindings operations.

func (*SinkUpdateAccessBindingsOperation) Metadata added in v0.0.10 

func (o *SinkUpdateAccessBindingsOperation) Metadata() *access.UpdateAccessBindingsMetadata

Metadata retrieves the operation metadata.

func (*SinkUpdateAccessBindingsOperation) Response 

func (o *SinkUpdateAccessBindingsOperation) Response() *emptypb.Empty

Response retrieves the operation response.

func (*SinkUpdateAccessBindingsOperation) Wait 

func (o *SinkUpdateAccessBindingsOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*emptypb.Empty, error)

Wait polls the operation until it's done.

func (*SinkUpdateAccessBindingsOperation) WaitInterval 

func (o *SinkUpdateAccessBindingsOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*emptypb.Empty, error)

WaitInterval polls the operation until it's done with custom interval.

type SinkUpdateOperation 

type SinkUpdateOperation struct {
	sdkop.Operation
}

SinkUpdateOperation is used to monitor the state of Update operations.

func (*SinkUpdateOperation) Metadata 

func (o *SinkUpdateOperation) Metadata() *logging.UpdateSinkMetadata

Metadata retrieves the operation metadata.

func (*SinkUpdateOperation) Response 

func (o *SinkUpdateOperation) Response() *logging.Sink

Response retrieves the operation response.

func (*SinkUpdateOperation) Wait 

func (o *SinkUpdateOperation) Wait(ctx context.Context, opts ...grpc.CallOption) (*logging.Sink, error)

Wait polls the operation until it's done.

func (*SinkUpdateOperation) WaitInterval 

func (o *SinkUpdateOperation) WaitInterval(ctx context.Context, pollInterval sdkop.PollIntervalFunc, opts ...grpc.CallOption) (*logging.Sink, error)

WaitInterval polls the operation until it's done with custom interval.

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.