Documentation
¶
Index ¶
- type StartOption
- type Store
- func (s *Store) Close()
- 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 ¶ added in v0.2.11
type StartOption func(*startOptions)
func WithJetStream ¶ added in v0.2.11
func WithJetStream(js jetstream.JetStream) StartOption
func WithNATSConnection ¶ added in v0.2.11
func WithNATSConnection(conn *natsgo.Conn, opts ...jetstream.JetStreamOpt) StartOption
func WithNATSURL ¶ added in v0.2.11
func WithNATSURL(url string, opts ...natsgo.Option) StartOption
type Store ¶
type Store struct {
*orisun.OrisunServer
// contains filtered or unexported fields
}
func (*Store) CreateBoundaryIndex ¶ added in v0.2.10
func (s *Store) CreateBoundaryIndex(ctx context.Context, boundary, name string, fields []orisun.BoundaryIndexField, conditions []orisun.BoundaryIndexCondition, combinator string) error
func (*Store) DropBoundaryIndex ¶ added in v0.2.10
func (*Store) NATSConnection ¶ added in v0.2.11
Source Files
Click to show internal directories.
Click to hide internal directories.