raw_client

Documentation

Index

• func NewAuthClient(cc *Conn) ctrlpb.AuthControllerClient
• func NewEventbusClient(cc *Conn) ctrlpb.EventbusControllerClient
• func NewEventlogClient(cc *Conn) ctrlpb.EventlogControllerClient
• func NewNamespaceClient(cc *Conn) ctrlpb.NamespaceControllerClient
• func NewPingClient(cc *Conn) ctrlpb.PingServerClient
• func NewSegmentClient(cc *Conn) ctrlpb.SegmentControllerClient
• func NewSnowflakeController(cc *Conn) ctrlpb.SnowflakeControllerClient
• func NewTriggerClient(cc *Conn) ctrlpb.TriggerControllerClient
• func RegisterHeartbeat(ctx context.Context, interval time.Duration, i interface{}, ...) error
• type Conn
  • func NewConnection(endpoints []string, credentials credentials.TransportCredentials) *Conn
• type Heartbeat

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
}