client

Documentation

Index

• type Option
  • func WithGRPCDialOption(opts ...grpc.DialOption) Option
  • func WithMaxBatchSize(size uint32) Option
  • func WithMaxWaitTime(d time.Duration) Option
  • func WithMinBatchSize(size uint32) Option
  • func WithTLSConfig(config *tls.Config) Option
• type TSOClient
  • func NewTSOClient(endpoints []string, opts ...Option) (*TSOClient, error)
  • func (c *TSOClient) Close()
  • func (c *TSOClient) GetTimestamp(ctx context.Context) (TSOFuture, error)
• type TSOFuture

Types

type Option

type Option func(*TSOClient)

func WithGRPCDialOption

func WithGRPCDialOption(opts ...grpc.DialOption) Option

func WithMaxBatchSize

func WithMaxBatchSize(size uint32) Option

func WithMaxWaitTime

func WithMaxWaitTime(d time.Duration) Option

func WithMinBatchSize

func WithMinBatchSize(size uint32) Option

func WithTLSConfig

func WithTLSConfig(config *tls.Config) Option

type TSOClient

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

Client state

func NewTSOClient

func NewTSOClient(endpoints []string, opts ...Option) (*TSOClient, error)

NewTSOClient creates a new TSO client

func (*TSOClient) Close

func (c *TSOClient) Close()

Close closes the client

func (*TSOClient) GetTimestamp

func (c *TSOClient) GetTimestamp(ctx context.Context) (TSOFuture, error)

GetTimestamp asynchronously gets a timestamp and returns a TSOFuture

type TSOFuture

type TSOFuture interface {
	// Wait gets the physical and logical time, it would block caller if data is not available yet.
	Wait() (int64, int64, error)
}