raw_client

package
v0.0.0-...-1334a7b Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAuthClient

func NewAuthClient(cc *Conn) ctrlpb.AuthControllerClient

func NewEventbusClient

func NewEventbusClient(cc *Conn) ctrlpb.EventbusControllerClient

func NewEventlogClient

func NewEventlogClient(cc *Conn) ctrlpb.EventlogControllerClient

func NewNamespaceClient

func NewNamespaceClient(cc *Conn) ctrlpb.NamespaceControllerClient

func NewPingClient

func NewPingClient(cc *Conn) ctrlpb.PingServerClient

func NewSegmentClient

func NewSegmentClient(cc *Conn) ctrlpb.SegmentControllerClient

func NewSnowflakeController

func NewSnowflakeController(cc *Conn) ctrlpb.SnowflakeControllerClient

func NewTriggerClient

func NewTriggerClient(cc *Conn) ctrlpb.TriggerControllerClient

func RegisterHeartbeat

func RegisterHeartbeat(ctx context.Context, interval time.Duration,
	i interface{}, reqFunc func() interface{},
) error

Types

type Conn

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

func NewConnection

func NewConnection(endpoints []string, credentials credentials.TransportCredentials) *Conn

type Heartbeat

type Heartbeat interface {
	Beat(ctx context.Context, req interface{}) error
}

Jump to

Keyboard shortcuts

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