databroker

Documentation

Overview

Package databroker is a pomerium service that handles the storage of user session state. It communicates over RPC with other pomerium services, and can be configured to use a number of different backend databroker stores.

Package databroker contains the databroker service.

Index

• type DataBroker
  • func New(cfg *config.Config) (*DataBroker, error)
  • func (c *DataBroker) OnConfigChange(ctx context.Context, cfg *config.Config)
  • func (c *DataBroker) RefreshUser(ctx context.Context, req *directory.RefreshUserRequest) (*emptypb.Empty, error)
  • func (c *DataBroker) Register(grpcServer *grpc.Server)
  • func (c *DataBroker) Run(ctx context.Context) error

Types

type DataBroker

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

DataBroker represents the databroker service. The databroker service is a simple interface for storing keyed blobs (bytes) of unstructured data.

func New

func New(cfg *config.Config) (*DataBroker, error)

New creates a new databroker service.

func (*DataBroker) OnConfigChange

func (c *DataBroker) OnConfigChange(ctx context.Context, cfg *config.Config)

OnConfigChange is called whenever configuration is changed.

func (*DataBroker) RefreshUser

func (c *DataBroker) RefreshUser(ctx context.Context, req *directory.RefreshUserRequest) (*emptypb.Empty, error)

RefreshUser refreshes a user's directory information.

func (*DataBroker) Register

func (c *DataBroker) Register(grpcServer *grpc.Server)

Register registers all the gRPC services with the given server.

func (*DataBroker) Run

func (c *DataBroker) Run(ctx context.Context) error

Run runs the databroker components.