databroker

package
v0.15.7 Latest Latest
Warning

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

 Go to latest Published: Nov 15, 2021 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

Package databroker contains a data broker implementation.

Index

Constants

This section is empty.

Variables

View Source 
var (
	// DefaultDeletePermanentlyAfter is the default amount of time to wait before deleting
	// a record permanently.
	DefaultDeletePermanentlyAfter = time.Hour
	// DefaultStorageType is the default storage type that Server use
	DefaultStorageType = "memory"
	// DefaultGetAllPageSize is the default page size for GetAll calls.
	DefaultGetAllPageSize = 50
	// DefaultRegistryTTL is the default registry time to live.
	DefaultRegistryTTL = time.Minute
)

Functions

This section is empty.

Types

type ConfigSource 

type ConfigSource struct {
	config.ChangeDispatcher
	// contains filtered or unexported fields
}

ConfigSource provides a new Config source that decorates an underlying config with configuration derived from the data broker.

func NewConfigSource 

func NewConfigSource(ctx context.Context, underlying config.Source, listeners ...config.ChangeListener) *ConfigSource

NewConfigSource creates a new ConfigSource.

func (*ConfigSource) GetConfig 

func (src *ConfigSource) GetConfig() *config.Config

GetConfig gets the current config.

type Server 

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

Server implements the databroker service using an in memory database.

func New 

func New(options ...ServerOption) *Server

New creates a new server.

func (*Server) AcquireLease added in v0.15.0 

func (srv *Server) AcquireLease(ctx context.Context, req *databroker.AcquireLeaseRequest) (*databroker.AcquireLeaseResponse, error)

AcquireLease acquires a lease.

func (*Server) Get 

func (srv *Server) Get(ctx context.Context, req *databroker.GetRequest) (*databroker.GetResponse, error)

Get gets a record from the in-memory list.

func (*Server) List added in v0.15.0 

func (srv *Server) List(ctx context.Context, req *registrypb.ListRequest) (*registrypb.ServiceList, error)

List calls the registry List method.

func (*Server) Put added in v0.14.0 

func (srv *Server) Put(ctx context.Context, req *databroker.PutRequest) (*databroker.PutResponse, error)

Put updates an existing record or adds a new one.

func (*Server) Query added in v0.11.0 

func (srv *Server) Query(ctx context.Context, req *databroker.QueryRequest) (*databroker.QueryResponse, error)

Query queries for records.

func (*Server) ReleaseLease added in v0.15.0 

func (srv *Server) ReleaseLease(ctx context.Context, req *databroker.ReleaseLeaseRequest) (*emptypb.Empty, error)

ReleaseLease releases a lease.

func (*Server) RenewLease added in v0.15.0 

func (srv *Server) RenewLease(ctx context.Context, req *databroker.RenewLeaseRequest) (*emptypb.Empty, error)

RenewLease releases a lease.

func (*Server) Report added in v0.15.0 

func (srv *Server) Report(ctx context.Context, req *registrypb.RegisterRequest) (*registrypb.RegisterResponse, error)

Report calls the registry Report method.

func (*Server) SetOptions added in v0.14.0 

func (srv *Server) SetOptions(ctx context.Context, req *databroker.SetOptionsRequest) (*databroker.SetOptionsResponse, error)

SetOptions sets options for a type in the databroker.

func (*Server) Sync 

func (srv *Server) Sync(req *databroker.SyncRequest, stream databroker.DataBrokerService_SyncServer) error

Sync streams updates for the given record type.

func (*Server) SyncLatest added in v0.14.0 

func (srv *Server) SyncLatest(req *databroker.SyncLatestRequest, stream databroker.DataBrokerService_SyncLatestServer) error

SyncLatest returns the latest value of every record in the databroker as a stream of records.

func (*Server) UpdateConfig added in v0.11.0 

func (srv *Server) UpdateConfig(options ...ServerOption)

UpdateConfig updates the server with the new options.

func (*Server) Watch added in v0.15.0 

func (srv *Server) Watch(req *registrypb.ListRequest, stream registrypb.Registry_WatchServer) error

Watch calls the registry Watch method.

type ServerOption 

type ServerOption func(*serverConfig)

A ServerOption customizes the server.

func WithDeletePermanentlyAfter 

func WithDeletePermanentlyAfter(dur time.Duration) ServerOption

WithDeletePermanentlyAfter sets the deletePermanentlyAfter duration. If a record is deleted via Delete, it will be permanently deleted after the given duration.

func WithGetAllPageSize added in v0.11.0 

func WithGetAllPageSize(pageSize int) ServerOption

WithGetAllPageSize sets the page size for GetAll calls.

func WithGetSharedKey added in v0.14.0 

func WithGetSharedKey(getSharedKey func() ([]byte, error)) ServerOption

WithGetSharedKey sets the secret in the config.

func WithRegistryTTL added in v0.15.0 

func WithRegistryTTL(ttl time.Duration) ServerOption

WithRegistryTTL sets the registry time to live in the config.

func WithStorageCAFile added in v0.11.0 

func WithStorageCAFile(filePath string) ServerOption

WithStorageCAFile sets the CA file in the config.

func WithStorageCertSkipVerify added in v0.11.0 

func WithStorageCertSkipVerify(storageCertSkipVerify bool) ServerOption

WithStorageCertSkipVerify sets the storageCertSkipVerify in the config.

func WithStorageCertificate added in v0.11.0 

func WithStorageCertificate(certificate *tls.Certificate) ServerOption

WithStorageCertificate sets the storageCertificate in the config.

func WithStorageConnectionString 

func WithStorageConnectionString(connStr string) ServerOption

WithStorageConnectionString sets the DSN for storage.

func WithStorageType 

func WithStorageType(typ string) ServerOption

WithStorageType sets the storage type.

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.