server

Documentation

Index

• Constants
• Variables
• func DeregisterAllFilters(model string) (ok bool)
• func DeregisterGraph(model string) bool
• func New(opt Options) api.SyncServer
• func RegisterFilters(model string, filters ...graph.Filter)
• func RegisterGraph(model string, graph graph.Graph) bool
• func ServerStreamWithContext(ss grpc.ServerStream, ctx context.Context) grpc.ServerStream
• type Filters
• type GraphResolver
• type Options
• type PeerValidator
• type PreSharedKey
  • func (psk PreSharedKey) Authn(ctx context.Context) (authz bool)
  • func (psk PreSharedKey) StreamInterceptor(srv any, ss grpc.ServerStream, _ *grpc.StreamServerInfo, ...) error
  • func (psk PreSharedKey) UnaryInterceptor(ctx context.Context, req any, _ *grpc.UnaryServerInfo, ...) (resp any, err error)

Constants

const (
	PSK_METADATA_KEY = "x-syncd-presharedkey"
)

Variables

var (
	DefaultOptions = Options{}
)

Functions

func DeregisterAllFilters

func DeregisterAllFilters(model string) (ok bool)

func DeregisterGraph

func DeregisterGraph(model string) bool

func New

func New(opt Options) api.SyncServer

func RegisterFilters

func RegisterFilters(model string, filters ...graph.Filter)

func RegisterGraph

func RegisterGraph(model string, graph graph.Graph) bool

func ServerStreamWithContext

func ServerStreamWithContext(ss grpc.ServerStream, ctx context.Context) grpc.ServerStream

Types

type Filters

type Filters map[string][]graph.Filter

type GraphResolver

type GraphResolver func(string) (graph.Graph, bool)

type Options

type Options struct {
	GraphResolver GraphResolver
	Filters       Filters
	PeerValidator PeerValidator
	Metrics       prometheus.Registerer
}

type PeerValidator

type PeerValidator func(string, string) bool

type PreSharedKey

type PreSharedKey string

func (PreSharedKey) Authn

func (psk PreSharedKey) Authn(ctx context.Context) (authz bool)

func (PreSharedKey) StreamInterceptor

func (psk PreSharedKey) StreamInterceptor(srv any, ss grpc.ServerStream, _ *grpc.StreamServerInfo, handler grpc.StreamHandler) error

func (PreSharedKey) UnaryInterceptor

func (psk PreSharedKey) UnaryInterceptor(ctx context.Context, req any, _ *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp any, err error)