acl

Documentation

Index

• Variables
• type AsyncSinkFactory
  • func (s AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)
• type AsyncSourceFactory
  • func (s AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)
• type Config
  • func ConfigFromFile(configFile string) (Config, error)
  • func ConfigFromString(configString string) (Config, error)
• type Scope

Variables

var (
	// ErrUnauthorized indicates that a client doesn't have access to a resource
	ErrUnauthorized = status.Errorf(codes.PermissionDenied, "unauthorised")
)

Types

type AsyncSinkFactory

type AsyncSinkFactory struct {
	Config Config
	Next   proximo.AsyncSinkFactory
}

func (AsyncSinkFactory) NewAsyncSink

func (s AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)

type AsyncSourceFactory

type AsyncSourceFactory struct {
	Config Config
	Next   proximo.AsyncSourceFactory
}

func (AsyncSourceFactory) NewAsyncSource

func (s AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)

type Config

type Config interface {
	GetClientScope(ctx context.Context) (*Scope, error)
}

Config allows retrieve of access scope for the current client

func ConfigFromFile

func ConfigFromFile(configFile string) (Config, error)

ConfigFromFile parses and compiles ACL config from a yaml file

func ConfigFromString

func ConfigFromString(configString string) (Config, error)

ConfigFromString parses and compiles ACL config from a string

type Scope

type Scope struct {
	Consume []*regexp.Regexp
	Publish []*regexp.Regexp
}

Scope contains the access rights for a particular client