res

package module

Go to main page

Versions in this module

v0

v0.4.7

Sep 1, 2023

Changes in this version

type Service

+ func (s *Service) SetInChannelSize(size int) *Service

+ func (s *Service) SetWorkerCount(count int) *Service

v0.4.6

Jan 17, 2022

v0.4.5

Sep 17, 2021

Changes in this version

type Service

+ func (s *Service) TokenEventWithID(cid string, tokenID string, token interface{})

+ func (s *Service) TokenReset(subject string, tokenID ...string)

v0.4.4

Jun 6, 2021

v0.4.3

Apr 16, 2021

v0.4.2

Dec 2, 2020

v0.4.1

Sep 25, 2020

v0.4.0

Jun 15, 2020

Changes in this version

+ func IsValidRID(rid string) bool

type AccessRequest

+ CID func() string

type Conn

+ ChanQueueSubscribe func(subject, queue string, ch chan *nats.Msg) (*nats.Subscription, error)

+ PublishRequest func(subject, reply string, data []byte) error

+ type DataValue struct

+ Data interface{}

type Service

+ func (s *Service) Conn() Conn

+ func (s *Service) SetQueueGroup(queue string) *Service

+ type SoftRef string

+ func (r *SoftRef) UnmarshalJSON(b []byte) error

+ func (r SoftRef) IsValid() bool

+ func (r SoftRef) MarshalJSON() ([]byte, error)

v0.3.0

Mar 4, 2020

Changes in this version

type Handler

+ func (h *Handler) Option(hf ...Option)

type Pattern

+ func (p Pattern) ReplaceTag(tag string, value string) Pattern

+ func (p Pattern) ReplaceTags(m map[string]string) Pattern

+ func (p Pattern) Values(s string) (map[string]string, bool)

v0.2.0

Jan 8, 2020

Changes in this version

+ const CodeInvalidQuery

+ var ErrInvalidQuery = &Error

type AccessRequest

+ InvalidQuery func(message string)

type AuthRequest

+ InvalidQuery func(message string)

+ Resource func(rid string)

type CallRequest

+ InvalidQuery func(message string)

+ Resource func(rid string)

type CollectionRequest

+ InvalidQuery func(message string)

+ type Event struct

+ Data interface{}

+ Idx int

+ Name string

+ NewValues map[string]interface{}

+ OldValues map[string]interface{}

+ Payload interface{}

+ Resource Resource

+ Value interface{}

type GetRequest

+ InvalidQuery func(message string)

type Handler

+ Listeners map[string]func(*Event)

+ OnRegister func(service *Service, pattern string)

+ type Match struct

+ Group string

+ Handler Handler

+ Listeners []func(*Event)

+ Params map[string]string

type ModelRequest

+ InvalidQuery func(message string)

type Mux

+ func (m *Mux) AddListener(pattern string, handler func(*Event))

+ func (m *Mux) Register(s *Service)

+ func (m *Mux) ValidateListeners() (err error)

type NewRequest

+ InvalidQuery func(message string)

type Option

+ func OnRegister(callback func(service *Service, pattern string)) Option

+ type Pattern string

+ func (p Pattern) IndexWildcard() int

+ func (p Pattern) IsValid() bool

+ func (p Pattern) Matches(s string) bool

type QueryRequest

+ Collection func(collection interface{})

+ InvalidQuery func(message string)

+ Model func(model interface{})

type Request

+ func (r *Request) InvalidQuery(message string)

+ func (r *Request) ResetEvent()

+ func (r *Request) Resource(rid string)

type Resource

+ ResetEvent func()

type Service

+ func (s *Service) ProtocolVersion() string

v0.1.0

Sep 13, 2019

Changes in this version

+ const CodeAccessDenied

+ const CodeBadRequest

+ const CodeInternalError

+ const CodeInvalidParams

+ const CodeMethodNotAllowed

+ const CodeMethodNotFound

+ const CodeNotFound

+ const CodeTimeout

+ const RequestTypeAccess

+ const RequestTypeAuth

+ const RequestTypeCall

+ const RequestTypeGet

+ var Collection = OptionFunc(func(hs *Handler) { ... })

+ var DeleteAction = &struct{ ... }

+ var ErrAccessDenied = &Error

+ var ErrInternalError = &Error

+ var ErrInvalidParams = &Error

+ var ErrMethodNotFound = &Error

+ var ErrNotFound = &Error

+ var ErrTimeout = &Error

+ var Model = OptionFunc(func(hs *Handler) { ... })

+ type AccessHandler func(AccessRequest)

+ var AccessDenied AccessHandler = func(r AccessRequest) { ... }

+ var AccessGranted AccessHandler = func(r AccessRequest) { ... }

+ type AccessRequest interface

+ Access func(get bool, call string)

+ AccessDenied func()

+ AccessGranted func()

+ Error func(err *Error)

+ NotFound func()

+ ParseToken func(interface{})

+ RawToken func() json.RawMessage

+ Timeout func(d time.Duration)

+ type ApplyAddHandler func(r Resource, value interface{}, idx int) error

+ type ApplyChangeHandler func(r Resource, changes map[string]interface{}) (map[string]interface{}, error)

+ type ApplyCreateHandler func(r Resource, data interface{}) error

+ type ApplyDeleteHandler func(r Resource) (interface{}, error)

+ type ApplyRemoveHandler func(r Resource, idx int) (interface{}, error)

+ type AuthHandler func(AuthRequest)

+ type AuthRequest interface

+ CID func() string

+ Error func(err *Error)

+ Header func() map[string][]string

+ Host func() string

+ InvalidParams func(message string)

+ Method func() string

+ MethodNotFound func()

+ NotFound func()

+ OK func(result interface{})

+ ParseParams func(interface{})

+ ParseToken func(interface{})

+ RawParams func() json.RawMessage

+ RawToken func() json.RawMessage

+ RemoteAddr func() string

+ Timeout func(d time.Duration)

+ TokenEvent func(t interface{})

+ URI func() string

+ type CallHandler func(CallRequest)

+ type CallRequest interface

+ CID func() string

+ Error func(err *Error)

+ InvalidParams func(message string)

+ Method func() string

+ MethodNotFound func()

+ NotFound func()

+ OK func(result interface{})

+ ParseParams func(interface{})

+ ParseToken func(interface{})

+ RawParams func() json.RawMessage

+ RawToken func() json.RawMessage

+ Timeout func(d time.Duration)

+ type CollectionHandler func(CollectionRequest)

+ type CollectionRequest interface

+ Collection func(collection interface{})

+ Error func(err *Error)

+ ForValue func() bool

+ NotFound func()

+ QueryCollection func(collection interface{}, query string)

+ Timeout func(d time.Duration)

+ type Conn interface

+ ChanSubscribe func(subject string, ch chan *nats.Msg) (*nats.Subscription, error)

+ Close func()

+ Publish func(subject string, payload []byte) error

+ type Error struct

+ Code string

+ Data interface{}

+ Message string

+ func InternalError(err error) *Error

+ func ToError(err error) *Error

+ func (e *Error) Error() string

+ type GetHandler func(GetRequest)

+ type GetRequest interface

+ Collection func(collection interface{})

+ Error func(err *Error)

+ ForValue func() bool

+ Model func(model interface{})

+ NotFound func()

+ QueryCollection func(collection interface{}, query string)

+ QueryModel func(model interface{}, query string)

+ Timeout func(d time.Duration)

+ type Handler struct

+ Access AccessHandler

+ ApplyAdd ApplyAddHandler

+ ApplyChange ApplyChangeHandler

+ ApplyCreate ApplyCreateHandler

+ ApplyDelete ApplyDeleteHandler

+ ApplyRemove ApplyRemoveHandler

+ Auth map[string]AuthHandler

+ Call map[string]CallHandler

+ Get GetHandler

+ Group string

+ New NewHandler

+ Type ResourceType

+ type ModelHandler func(ModelRequest)

+ type ModelRequest interface

+ Error func(err *Error)

+ ForValue func() bool

+ Model func(model interface{})

+ NotFound func()

+ QueryModel func(model interface{}, query string)

+ Timeout func(d time.Duration)

+ type Mux struct

+ func NewMux(path string) *Mux

+ func (m *Mux) AddHandler(pattern string, hs Handler)

+ func (m *Mux) Contains(test func(h Handler) bool) bool

+ func (m *Mux) FullPath() string

+ func (m *Mux) GetHandler(rname string) (Handler, map[string]string, string, error)

+ func (m *Mux) Handle(pattern string, hf ...Option)

+ func (m *Mux) Mount(path string, sub *Mux)

+ func (m *Mux) Path() string

+ func (m *Mux) Route(subpath string, fn func(m *Mux)) *Mux

+ type NewHandler func(NewRequest)

+ type NewRequest interface

+ CID func() string

+ Error func(err *Error)

+ InvalidParams func(message string)

+ MethodNotFound func()

+ New func(rid Ref)

+ NotFound func()

+ ParseParams func(interface{})

+ ParseToken func(interface{})

+ RawParams func() json.RawMessage

+ RawToken func() json.RawMessage

+ Timeout func(d time.Duration)

+ type Option interface

+ SetOption func(*Handler)

+ func Access(h AccessHandler) Option

+ func ApplyAdd(h ApplyAddHandler) Option

+ func ApplyChange(h ApplyChangeHandler) Option

+ func ApplyCreate(h ApplyCreateHandler) Option

+ func ApplyDelete(h ApplyDeleteHandler) Option

+ func ApplyRemove(h ApplyRemoveHandler) Option

+ func Auth(method string, h AuthHandler) Option

+ func Call(method string, h CallHandler) Option

+ func GetCollection(h CollectionHandler) Option

+ func GetModel(h ModelHandler) Option

+ func GetResource(h GetHandler) Option

+ func Group(group string) Option

+ func New(h NewHandler) Option

+ func Set(h CallHandler) Option

+ type OptionFunc func(*Handler)

+ func (f OptionFunc) SetOption(hs *Handler)

+ type QueryRequest interface

+ Error func(err *Error)

+ NotFound func()

+ Timeout func(d time.Duration)

+ type Ref string

+ func (r *Ref) UnmarshalJSON(b []byte) error

+ func (r Ref) IsValid() bool

+ func (r Ref) MarshalJSON() ([]byte, error)

+ type Request struct

+ func (r *Request) Access(get bool, call string)

+ func (r *Request) AccessDenied()

+ func (r *Request) AccessGranted()

+ func (r *Request) AddEvent(v interface{}, idx int)

+ func (r *Request) CID() string

+ func (r *Request) ChangeEvent(ev map[string]interface{})

+ func (r *Request) Collection(collection interface{})

+ func (r *Request) CreateEvent(value interface{})

+ func (r *Request) DeleteEvent()

+ func (r *Request) Error(err *Error)

+ func (r *Request) Event(event string, payload interface{})

+ func (r *Request) ForValue() bool

+ func (r *Request) Group() string

+ func (r *Request) Header() map[string][]string

+ func (r *Request) Host() string

+ func (r *Request) InvalidParams(message string)

+ func (r *Request) Method() string

+ func (r *Request) MethodNotFound()

+ func (r *Request) Model(model interface{})

+ func (r *Request) New(rid Ref)

+ func (r *Request) NotFound()

+ func (r *Request) OK(result interface{})

+ func (r *Request) ParseParams(p interface{})

+ func (r *Request) ParseQuery() url.Values

+ func (r *Request) ParseToken(t interface{})

+ func (r *Request) PathParam(key string) string

+ func (r *Request) PathParams() map[string]string

+ func (r *Request) Query() string

+ func (r *Request) QueryCollection(collection interface{}, query string)

+ func (r *Request) QueryEvent(cb func(QueryRequest))

+ func (r *Request) QueryModel(model interface{}, query string)

+ func (r *Request) RawParams() json.RawMessage

+ func (r *Request) RawToken() json.RawMessage

+ func (r *Request) ReaccessEvent()

+ func (r *Request) RemoteAddr() string

+ func (r *Request) RemoveEvent(idx int)

+ func (r *Request) RequireValue() interface{}

+ func (r *Request) ResourceName() string

+ func (r *Request) ResourceType() ResourceType

+ func (r *Request) Service() *Service

+ func (r *Request) Timeout(d time.Duration)

+ func (r *Request) TokenEvent(token interface{})

+ func (r *Request) Type() string

+ func (r *Request) URI() string

+ func (r *Request) Value() (interface{}, error)

+ type Resource interface

+ AddEvent func(value interface{}, idx int)

+ ChangeEvent func(props map[string]interface{})

+ CreateEvent func(value interface{})

+ DeleteEvent func()

+ Event func(event string, payload interface{})

+ Group func() string

+ ParseQuery func() url.Values

+ PathParam func(string) string

+ PathParams func() map[string]string

+ Query func() string

+ QueryEvent func(func(QueryRequest))

+ ReaccessEvent func()

+ RemoveEvent func(idx int)

+ RequireValue func() interface{}

+ ResourceName func() string

+ ResourceType func() ResourceType

+ Service func() *Service

+ Value func() (interface{}, error)

+ type ResourceType byte

+ const TypeCollection

+ const TypeModel

+ const TypeUnset

+ type Service struct

+ func NewService(name string) *Service

+ func (s *Service) ListenAndServe(url string, options ...nats.Option) error

+ func (s *Service) Logger() logger.Logger

+ func (s *Service) Reset(resources []string, access []string)

+ func (s *Service) ResetAll()

+ func (s *Service) Resource(rid string) (Resource, error)

+ func (s *Service) Serve(nc Conn) error

+ func (s *Service) SetLogger(l logger.Logger) *Service

+ func (s *Service) SetOnDisconnect(f func(*Service))

+ func (s *Service) SetOnError(f func(*Service, string))

+ func (s *Service) SetOnReconnect(f func(*Service))

+ func (s *Service) SetOnServe(f func(*Service))

+ func (s *Service) SetOwnedResources(resources, access []string) *Service

+ func (s *Service) SetQueryEventDuration(d time.Duration) *Service

+ func (s *Service) SetReset(resources, access []string) *Service

+ func (s *Service) Shutdown() error

+ func (s *Service) TokenEvent(cid string, token interface{})

+ func (s *Service) With(rid string, cb func(r Resource)) error

+ func (s *Service) WithGroup(group string, cb func(s *Service))

+ func (s *Service) WithResource(r Resource, cb func())

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