eventrouter

package
v0.0.0-...-2393e24 Latest Latest
Warning

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

 Go to latest Published: Dec 20, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

nolint

nolint

nolint

nolint

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BusAccessBindingsIterator 

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

func (*BusAccessBindingsIterator) Error 

func (it *BusAccessBindingsIterator) Error() error

func (*BusAccessBindingsIterator) Next 

func (it *BusAccessBindingsIterator) Next() bool

func (*BusAccessBindingsIterator) Take 

func (it *BusAccessBindingsIterator) Take(size int64) ([]*access.AccessBinding, error)

func (*BusAccessBindingsIterator) TakeAll 

func (it *BusAccessBindingsIterator) TakeAll() ([]*access.AccessBinding, error)

func (*BusAccessBindingsIterator) Value 

func (it *BusAccessBindingsIterator) Value() *access.AccessBinding

type BusIterator 

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

func (*BusIterator) Error 

func (it *BusIterator) Error() error

func (*BusIterator) Next 

func (it *BusIterator) Next() bool

func (*BusIterator) Take 

func (it *BusIterator) Take(size int64) ([]*eventrouter.Bus, error)

func (*BusIterator) TakeAll 

func (it *BusIterator) TakeAll() ([]*eventrouter.Bus, error)

func (*BusIterator) Value 

func (it *BusIterator) Value() *eventrouter.Bus

type BusOperationsIterator 

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

func (*BusOperationsIterator) Error 

func (it *BusOperationsIterator) Error() error

func (*BusOperationsIterator) Next 

func (it *BusOperationsIterator) Next() bool

func (*BusOperationsIterator) Take 

func (it *BusOperationsIterator) Take(size int64) ([]*operation.Operation, error)

func (*BusOperationsIterator) TakeAll 

func (it *BusOperationsIterator) TakeAll() ([]*operation.Operation, error)

func (*BusOperationsIterator) Value 

func (it *BusOperationsIterator) Value() *operation.Operation

type BusServiceClient 

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

BusServiceClient is a eventrouter.BusServiceClient with lazy GRPC connection initialization.

func (*BusServiceClient) BusAccessBindingsIterator 

func (c *BusServiceClient) BusAccessBindingsIterator(ctx context.Context, req *access.ListAccessBindingsRequest, opts ...grpc.CallOption) *BusAccessBindingsIterator

func (*BusServiceClient) BusIterator 

func (c *BusServiceClient) BusIterator(ctx context.Context, req *eventrouter.ListBusesRequest, opts ...grpc.CallOption) *BusIterator

func (*BusServiceClient) BusOperationsIterator 

func (c *BusServiceClient) BusOperationsIterator(ctx context.Context, req *eventrouter.ListBusOperationsRequest, opts ...grpc.CallOption) *BusOperationsIterator

func (*BusServiceClient) Create 

func (c *BusServiceClient) Create(ctx context.Context, in *eventrouter.CreateBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements eventrouter.BusServiceClient

func (*BusServiceClient) Delete 

func (c *BusServiceClient) Delete(ctx context.Context, in *eventrouter.DeleteBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements eventrouter.BusServiceClient

func (*BusServiceClient) Get 

func (c *BusServiceClient) Get(ctx context.Context, in *eventrouter.GetBusRequest, opts ...grpc.CallOption) (*eventrouter.Bus, error)

Get implements eventrouter.BusServiceClient

func (*BusServiceClient) List 

func (c *BusServiceClient) List(ctx context.Context, in *eventrouter.ListBusesRequest, opts ...grpc.CallOption) (*eventrouter.ListBusesResponse, error)

List implements eventrouter.BusServiceClient

func (*BusServiceClient) ListAccessBindings 

func (c *BusServiceClient) ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)

ListAccessBindings implements eventrouter.BusServiceClient

func (*BusServiceClient) ListOperations 

func (c *BusServiceClient) ListOperations(ctx context.Context, in *eventrouter.ListBusOperationsRequest, opts ...grpc.CallOption) (*eventrouter.ListBusOperationsResponse, error)

ListOperations implements eventrouter.BusServiceClient

func (*BusServiceClient) SetAccessBindings 

func (c *BusServiceClient) SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

SetAccessBindings implements eventrouter.BusServiceClient

func (*BusServiceClient) Update 

func (c *BusServiceClient) Update(ctx context.Context, in *eventrouter.UpdateBusRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements eventrouter.BusServiceClient

func (*BusServiceClient) UpdateAccessBindings 

func (c *BusServiceClient) UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateAccessBindings implements eventrouter.BusServiceClient

type ConnectorAccessBindingsIterator 

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

func (*ConnectorAccessBindingsIterator) Error 

func (it *ConnectorAccessBindingsIterator) Error() error

func (*ConnectorAccessBindingsIterator) Next 

func (it *ConnectorAccessBindingsIterator) Next() bool

func (*ConnectorAccessBindingsIterator) Take 

func (it *ConnectorAccessBindingsIterator) Take(size int64) ([]*access.AccessBinding, error)

func (*ConnectorAccessBindingsIterator) TakeAll 

func (it *ConnectorAccessBindingsIterator) TakeAll() ([]*access.AccessBinding, error)

func (*ConnectorAccessBindingsIterator) Value 

func (it *ConnectorAccessBindingsIterator) Value() *access.AccessBinding

type ConnectorIterator 

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

func (*ConnectorIterator) Error 

func (it *ConnectorIterator) Error() error

func (*ConnectorIterator) Next 

func (it *ConnectorIterator) Next() bool

func (*ConnectorIterator) Take 

func (it *ConnectorIterator) Take(size int64) ([]*eventrouter.Connector, error)

func (*ConnectorIterator) TakeAll 

func (it *ConnectorIterator) TakeAll() ([]*eventrouter.Connector, error)

func (*ConnectorIterator) Value 

func (it *ConnectorIterator) Value() *eventrouter.Connector

type ConnectorOperationsIterator 

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

func (*ConnectorOperationsIterator) Error 

func (it *ConnectorOperationsIterator) Error() error

func (*ConnectorOperationsIterator) Next 

func (it *ConnectorOperationsIterator) Next() bool

func (*ConnectorOperationsIterator) Take 

func (it *ConnectorOperationsIterator) Take(size int64) ([]*operation.Operation, error)

func (*ConnectorOperationsIterator) TakeAll 

func (it *ConnectorOperationsIterator) TakeAll() ([]*operation.Operation, error)

func (*ConnectorOperationsIterator) Value 

func (it *ConnectorOperationsIterator) Value() *operation.Operation

type ConnectorServiceClient 

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

ConnectorServiceClient is a eventrouter.ConnectorServiceClient with lazy GRPC connection initialization.

func (*ConnectorServiceClient) ConnectorAccessBindingsIterator 

func (c *ConnectorServiceClient) ConnectorAccessBindingsIterator(ctx context.Context, req *access.ListAccessBindingsRequest, opts ...grpc.CallOption) *ConnectorAccessBindingsIterator

func (*ConnectorServiceClient) ConnectorIterator 

func (c *ConnectorServiceClient) ConnectorIterator(ctx context.Context, req *eventrouter.ListConnectorsRequest, opts ...grpc.CallOption) *ConnectorIterator

func (*ConnectorServiceClient) ConnectorOperationsIterator 

func (c *ConnectorServiceClient) ConnectorOperationsIterator(ctx context.Context, req *eventrouter.ListConnectorOperationsRequest, opts ...grpc.CallOption) *ConnectorOperationsIterator

func (*ConnectorServiceClient) Create 

func (c *ConnectorServiceClient) Create(ctx context.Context, in *eventrouter.CreateConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) Delete 

func (c *ConnectorServiceClient) Delete(ctx context.Context, in *eventrouter.DeleteConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) Get 

func (c *ConnectorServiceClient) Get(ctx context.Context, in *eventrouter.GetConnectorRequest, opts ...grpc.CallOption) (*eventrouter.Connector, error)

Get implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) List 

func (c *ConnectorServiceClient) List(ctx context.Context, in *eventrouter.ListConnectorsRequest, opts ...grpc.CallOption) (*eventrouter.ListConnectorsResponse, error)

List implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) ListAccessBindings 

func (c *ConnectorServiceClient) ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)

ListAccessBindings implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) ListOperations 

func (c *ConnectorServiceClient) ListOperations(ctx context.Context, in *eventrouter.ListConnectorOperationsRequest, opts ...grpc.CallOption) (*eventrouter.ListConnectorOperationsResponse, error)

ListOperations implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) SetAccessBindings 

func (c *ConnectorServiceClient) SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

SetAccessBindings implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) Start 

func (c *ConnectorServiceClient) Start(ctx context.Context, in *eventrouter.StartConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Start implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) Stop 

func (c *ConnectorServiceClient) Stop(ctx context.Context, in *eventrouter.StopConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Stop implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) Update 

func (c *ConnectorServiceClient) Update(ctx context.Context, in *eventrouter.UpdateConnectorRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements eventrouter.ConnectorServiceClient

func (*ConnectorServiceClient) UpdateAccessBindings 

func (c *ConnectorServiceClient) UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateAccessBindings implements eventrouter.ConnectorServiceClient

type EventServiceClient 

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

EventServiceClient is a eventrouter.EventServiceClient with lazy GRPC connection initialization.

func (*EventServiceClient) Put 

func (c *EventServiceClient) Put(ctx context.Context, in *eventrouter.PutEventRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

Put implements eventrouter.EventServiceClient

type Eventrouter 

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

Eventrouter provides access to "eventrouter" component of Yandex.Cloud

func NewEventrouter 

func NewEventrouter(g func(ctx context.Context) (*grpc.ClientConn, error)) *Eventrouter

NewEventrouter creates instance of Eventrouter

func (*Eventrouter) Bus 

func (e *Eventrouter) Bus() *BusServiceClient

Bus gets BusService client

func (*Eventrouter) Connector 

func (e *Eventrouter) Connector() *ConnectorServiceClient

Connector gets ConnectorService client

func (*Eventrouter) Event 

func (e *Eventrouter) Event() *EventServiceClient

Event gets EventService client

func (*Eventrouter) Rule 

func (e *Eventrouter) Rule() *RuleServiceClient

Rule gets RuleService client

type RuleAccessBindingsIterator 

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

func (*RuleAccessBindingsIterator) Error 

func (it *RuleAccessBindingsIterator) Error() error

func (*RuleAccessBindingsIterator) Next 

func (it *RuleAccessBindingsIterator) Next() bool

func (*RuleAccessBindingsIterator) Take 

func (it *RuleAccessBindingsIterator) Take(size int64) ([]*access.AccessBinding, error)

func (*RuleAccessBindingsIterator) TakeAll 

func (it *RuleAccessBindingsIterator) TakeAll() ([]*access.AccessBinding, error)

func (*RuleAccessBindingsIterator) Value 

func (it *RuleAccessBindingsIterator) Value() *access.AccessBinding

type RuleIterator 

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

func (*RuleIterator) Error 

func (it *RuleIterator) Error() error

func (*RuleIterator) Next 

func (it *RuleIterator) Next() bool

func (*RuleIterator) Take 

func (it *RuleIterator) Take(size int64) ([]*eventrouter.Rule, error)

func (*RuleIterator) TakeAll 

func (it *RuleIterator) TakeAll() ([]*eventrouter.Rule, error)

func (*RuleIterator) Value 

func (it *RuleIterator) Value() *eventrouter.Rule

type RuleOperationsIterator 

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

func (*RuleOperationsIterator) Error 

func (it *RuleOperationsIterator) Error() error

func (*RuleOperationsIterator) Next 

func (it *RuleOperationsIterator) Next() bool

func (*RuleOperationsIterator) Take 

func (it *RuleOperationsIterator) Take(size int64) ([]*operation.Operation, error)

func (*RuleOperationsIterator) TakeAll 

func (it *RuleOperationsIterator) TakeAll() ([]*operation.Operation, error)

func (*RuleOperationsIterator) Value 

func (it *RuleOperationsIterator) Value() *operation.Operation

type RuleServiceClient 

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

RuleServiceClient is a eventrouter.RuleServiceClient with lazy GRPC connection initialization.

func (*RuleServiceClient) Create 

func (c *RuleServiceClient) Create(ctx context.Context, in *eventrouter.CreateRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Create implements eventrouter.RuleServiceClient

func (*RuleServiceClient) Delete 

func (c *RuleServiceClient) Delete(ctx context.Context, in *eventrouter.DeleteRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Delete implements eventrouter.RuleServiceClient

func (*RuleServiceClient) Disable 

func (c *RuleServiceClient) Disable(ctx context.Context, in *eventrouter.DisableRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Disable implements eventrouter.RuleServiceClient

func (*RuleServiceClient) Enable 

func (c *RuleServiceClient) Enable(ctx context.Context, in *eventrouter.EnableRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Enable implements eventrouter.RuleServiceClient

func (*RuleServiceClient) Get 

func (c *RuleServiceClient) Get(ctx context.Context, in *eventrouter.GetRuleRequest, opts ...grpc.CallOption) (*eventrouter.Rule, error)

Get implements eventrouter.RuleServiceClient

func (*RuleServiceClient) List 

func (c *RuleServiceClient) List(ctx context.Context, in *eventrouter.ListRulesRequest, opts ...grpc.CallOption) (*eventrouter.ListRulesResponse, error)

List implements eventrouter.RuleServiceClient

func (*RuleServiceClient) ListAccessBindings 

func (c *RuleServiceClient) ListAccessBindings(ctx context.Context, in *access.ListAccessBindingsRequest, opts ...grpc.CallOption) (*access.ListAccessBindingsResponse, error)

ListAccessBindings implements eventrouter.RuleServiceClient

func (*RuleServiceClient) ListOperations 

func (c *RuleServiceClient) ListOperations(ctx context.Context, in *eventrouter.ListRuleOperationsRequest, opts ...grpc.CallOption) (*eventrouter.ListRuleOperationsResponse, error)

ListOperations implements eventrouter.RuleServiceClient

func (*RuleServiceClient) RuleAccessBindingsIterator 

func (c *RuleServiceClient) RuleAccessBindingsIterator(ctx context.Context, req *access.ListAccessBindingsRequest, opts ...grpc.CallOption) *RuleAccessBindingsIterator

func (*RuleServiceClient) RuleIterator 

func (c *RuleServiceClient) RuleIterator(ctx context.Context, req *eventrouter.ListRulesRequest, opts ...grpc.CallOption) *RuleIterator

func (*RuleServiceClient) RuleOperationsIterator 

func (c *RuleServiceClient) RuleOperationsIterator(ctx context.Context, req *eventrouter.ListRuleOperationsRequest, opts ...grpc.CallOption) *RuleOperationsIterator

func (*RuleServiceClient) SetAccessBindings 

func (c *RuleServiceClient) SetAccessBindings(ctx context.Context, in *access.SetAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

SetAccessBindings implements eventrouter.RuleServiceClient

func (*RuleServiceClient) Update 

func (c *RuleServiceClient) Update(ctx context.Context, in *eventrouter.UpdateRuleRequest, opts ...grpc.CallOption) (*operation.Operation, error)

Update implements eventrouter.RuleServiceClient

func (*RuleServiceClient) UpdateAccessBindings 

func (c *RuleServiceClient) UpdateAccessBindings(ctx context.Context, in *access.UpdateAccessBindingsRequest, opts ...grpc.CallOption) (*operation.Operation, error)

UpdateAccessBindings implements eventrouter.RuleServiceClient

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.