Documentation
¶
Index ¶
- func NewInMemory() event.Store
- type InMemoryStore
- func (s *InMemoryStore) CreateRendezvous(ctx context.Context, rendezvous *event.Rendezvous) error
- func (s *InMemoryStore) DeleteRendezvous(ctx context.Context, key, address string) error
- func (s *InMemoryStore) ExtendRendezvousExpiry(ctx context.Context, key, address string, expiresAt time.Time) error
- func (s *InMemoryStore) GetRendezvous(ctx context.Context, key string) (*event.Rendezvous, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewInMemory ¶
Types ¶
type InMemoryStore ¶
type InMemoryStore struct {
// contains filtered or unexported fields
}
func (*InMemoryStore) CreateRendezvous ¶
func (s *InMemoryStore) CreateRendezvous(ctx context.Context, rendezvous *event.Rendezvous) error
func (*InMemoryStore) DeleteRendezvous ¶
func (s *InMemoryStore) DeleteRendezvous(ctx context.Context, key, address string) error
func (*InMemoryStore) ExtendRendezvousExpiry ¶
func (*InMemoryStore) GetRendezvous ¶
func (s *InMemoryStore) GetRendezvous(ctx context.Context, key string) (*event.Rendezvous, error)
Source Files
Click to show internal directories.
Click to hide internal directories.