Documentation
¶
Index ¶
- type StartOption
- type Store
- func (s *Store) Close(ctx context.Context)
- func (s *Store) CreateBoundaryIndex(ctx context.Context, boundary, name string, fields []orisun.BoundaryIndexField, ...) error
- func (s *Store) DropBoundaryIndex(ctx context.Context, boundary, name string) error
- func (s *Store) JetStream() jetstream.JetStream
- func (s *Store) NATSConnection() *natsgo.Conn
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type StartOption ¶
type StartOption func(*startOptions)
func WithJetStream ¶
func WithJetStream(js jetstream.JetStream) StartOption
func WithNATSConnection ¶
func WithNATSConnection(conn *natsgo.Conn, opts ...jetstream.JetStreamOpt) StartOption
func WithNATSURL ¶
func WithNATSURL(url string, opts ...natsgo.Option) StartOption
type Store ¶
type Store struct {
*orisun.OrisunServer
// contains filtered or unexported fields
}
func (*Store) CreateBoundaryIndex ¶
func (s *Store) CreateBoundaryIndex(ctx context.Context, boundary, name string, fields []orisun.BoundaryIndexField, conditions []orisun.BoundaryIndexCondition, combinator string) error
func (*Store) DropBoundaryIndex ¶
func (*Store) NATSConnection ¶
Source Files
Click to show internal directories.
Click to hide internal directories.