manager

package

v0.4.0 Latest Latest Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation ¶

Index ¶

Constants
func GenerateBytesUUID() []byte
func GenerateUUID() string
func New(serviceProvider driver.ServiceProvider, commLayer CommLayer, ...) *manager
func NewContext(context context.Context, sp driver.ServiceProvider, contextID string, ...) (*ctx, error)
func NewContextForInitiator(contextID string, context context.Context, sp driver.ServiceProvider, ...) (*ctx, error)
type CommLayer
- func GetCommLayer(sp driver.ServiceProvider) CommLayer
type Metrics
type SessionFactory

Constants ¶

const (
	SuccessLabel       tracing.LabelName = "success"
	ViewLabel          tracing.LabelName = "view"
	InitiatorViewLabel tracing.LabelName = "initiator_view"
)

Variables ¶

This section is empty.

Functions ¶

func GenerateBytesUUID ¶

func GenerateBytesUUID() []byte

GenerateBytesUUID returns a UUID based on RFC 4122 returning the generated bytes

func GenerateUUID ¶

func GenerateUUID() string

GenerateUUID returns a UUID based on RFC 4122

func New ¶

func New(serviceProvider driver.ServiceProvider, commLayer CommLayer, endpointService driver.EndpointService, identityProvider driver.IdentityProvider, provider trace.TracerProvider, metricsProvider metrics.Provider) *manager

func NewContext ¶

func NewContext(context context.Context, sp driver.ServiceProvider, contextID string, sessionFactory SessionFactory, resolver driver.EndpointService, party view.Identity, session view.Session, caller view.Identity, tracer trace.Tracer) (*ctx, error)

func NewContextForInitiator ¶

func NewContextForInitiator(contextID string, context context.Context, sp driver.ServiceProvider, sessionFactory SessionFactory, resolver driver.EndpointService, party view.Identity, initiator view.View, tracer trace.Tracer) (*ctx, error)

Types ¶

type CommLayer ¶

type CommLayer interface {
	NewSessionWithID(sessionID, contextID, endpoint string, pkid []byte, caller view.Identity, msg *view.Message) (view.Session, error)

	NewSession(caller string, contextID string, endpoint string, pkid []byte) (view.Session, error)

	MasterSession() (view.Session, error)

	DeleteSessions(ctx context.Context, sessionID string)
}

func GetCommLayer ¶

func GetCommLayer(sp driver.ServiceProvider) CommLayer

type Metrics ¶ added in v0.4.0

type Metrics struct {
	Contexts metrics.Gauge
}

type SessionFactory ¶

type SessionFactory interface {
	NewSessionWithID(sessionID, contextID, endpoint string, pkid []byte, caller view.Identity, msg *view.Message) (view.Session, error)

	NewSession(caller string, contextID string, endpoint string, pkid []byte) (view.Session, error)

	DeleteSessions(ctx context.Context, sessionID string)
}

SessionFactory is used to create new communication sessions

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
mock Code generated by counterfeiter.	Code generated by counterfeiter.

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL