storage

Documentation

Index

• func MutualPrefixCheck(prefix, other string) bool
• type BucketEventListener
• type BucketListenerManager
  • func New() *BucketListenerManager
  • func (b *BucketListenerManager) HandleRequest(request *storagepb.ServerMessage) (*storagepb.ClientMessage, error)
  • func (b *BucketListenerManager) Listen(stream storagepb.StorageListener_ListenServer) error
  • func (b *BucketListenerManager) RegisterNewListener(registration *storagepb.RegistrationRequest, ...) (*WorkerConnection, error)
  • func (b *BucketListenerManager) WorkerCount() int
• type BucketName
• type BucketRequestHandler
• type WorkerConnection

Functions

func MutualPrefixCheck

func MutualPrefixCheck(prefix, other string) bool

MutualPrefixCheck returns true if either string starts with the other

Types

type BucketEventListener

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

BucketEventListener listens for specific events on a storage bucket

type BucketListenerManager

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

BucketListenerManager manages storage listeners for different buckets

func New

func New() *BucketListenerManager

func (*BucketListenerManager) HandleRequest

func (b *BucketListenerManager) HandleRequest(request *storagepb.ServerMessage) (*storagepb.ClientMessage, error)

HandleRequest processes incoming requests and directs them to the appropriate listener

func (*BucketListenerManager) Listen

func (b *BucketListenerManager) Listen(stream storagepb.StorageListener_ListenServer) error

Listen handles incoming stream connections for storage events

func (*BucketListenerManager) RegisterNewListener

func (b *BucketListenerManager) RegisterNewListener(registration *storagepb.RegistrationRequest, stream storagepb.StorageListener_ListenServer) (*WorkerConnection, error)

RegisterNewListener adds a new listener for a given registration request

func (*BucketListenerManager) WorkerCount

func (b *BucketListenerManager) WorkerCount() int

WorkerCount returns the total number of workers across all listeners

type BucketName

type BucketName = string

BucketName uniquely identifies a storage bucket

type BucketRequestHandler

type BucketRequestHandler interface {
	storagepb.StorageListenerServer
	HandleRequest(request *storagepb.ServerMessage) (*storagepb.ClientMessage, error)
	WorkerCount() int
}

type WorkerConnection

type WorkerConnection = workers.WorkerRequestBroker[*storagepb.ServerMessage, *storagepb.ClientMessage]

WorkerConnection handles communication between storage and worker