server

Documentation

Index

• Constants
• Variables
• type Restate
  • func NewRestate() *Restate
  • func (r *Restate) Bind(router restate.Router) *Restate
  • func (r *Restate) Start(ctx context.Context, address string) error
  • func (r *Restate) WithIdentityV1(keys ...string) *Restate
  • func (r *Restate) WithLogger(h slog.Handler, dropReplayLogs bool) *Restate

Constants

const MAX_SERVICE_DISCOVERY_PROTOCOL_VERSION discovery.ServiceDiscoveryProtocolVersion = discovery.ServiceDiscoveryProtocolVersion_V1

const MAX_SERVICE_PROTOCOL_VERSION protocol.ServiceProtocolVersion = protocol.ServiceProtocolVersion_V1

const MIN_SERVICE_DISCOVERY_PROTOCOL_VERSION discovery.ServiceDiscoveryProtocolVersion = discovery.ServiceDiscoveryProtocolVersion_V1

const MIN_SERVICE_PROTOCOL_VERSION protocol.ServiceProtocolVersion = protocol.ServiceProtocolVersion_V1

Variables

var X_RESTATE_SERVER = `restate-sdk-go/unknown`

Types

type Restate

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

func NewRestate

func NewRestate() *Restate

NewRestate creates a new instance of Restate server

func (*Restate) Bind

func (r *Restate) Bind(router restate.Router) *Restate

func (*Restate) Start

func (r *Restate) Start(ctx context.Context, address string) error

func (*Restate) WithIdentityV1

func (r *Restate) WithIdentityV1(keys ...string) *Restate

func (*Restate) WithLogger

func (r *Restate) WithLogger(h slog.Handler, dropReplayLogs bool) *Restate

WithLogger overrides the slog handler used by the SDK (which defaults to the slog Default()) You may specify with dropReplayLogs whether to drop logs that originated from handler code while the invocation was replaying. If they are not dropped, you may still determine the replay status in a slog.Handler using rcontext.LogContextFrom(ctx)