bucket

Documentation

Index

• type FakeBucket
• type FakeBucketClass
• type FakeEvent
• type FakeRuntimeService
  • func NewFakeRuntimeService() *FakeRuntimeService
  • func (r *FakeRuntimeService) CreateBucket(ctx context.Context, req *iri.CreateBucketRequest) (*iri.CreateBucketResponse, error)
  • func (r *FakeRuntimeService) DeleteBucket(ctx context.Context, req *iri.DeleteBucketRequest) (*iri.DeleteBucketResponse, error)
  • func (r *FakeRuntimeService) ListBucketClasses(ctx context.Context, req *iri.ListBucketClassesRequest) (*iri.ListBucketClassesResponse, error)
  • func (r *FakeRuntimeService) ListBuckets(ctx context.Context, req *iri.ListBucketsRequest) (*iri.ListBucketsResponse, error)
  • func (r *FakeRuntimeService) ListEvents(ctx context.Context, req *iri.ListEventsRequest) (*iri.ListEventsResponse, error)
  • func (r *FakeRuntimeService) SetBucketClasses(bucketClasses []*FakeBucketClass)
  • func (r *FakeRuntimeService) SetBuckets(buckets []*FakeBucket)
  • func (r *FakeRuntimeService) SetEvents(events []*FakeEvent)

Types

type FakeBucket

type FakeBucket struct {
	iri.Bucket
}

type FakeBucketClass

type FakeBucketClass struct {
	iri.BucketClass
}

type FakeEvent

type FakeEvent struct {
	irievent.Event
}

type FakeRuntimeService

type FakeRuntimeService struct {
	sync.Mutex

	Buckets       map[string]*FakeBucket
	BucketClasses map[string]*FakeBucketClass
	Events        []*FakeEvent
	// contains filtered or unexported fields
}

func NewFakeRuntimeService

func NewFakeRuntimeService() *FakeRuntimeService

func (*FakeRuntimeService) CreateBucket

func (r *FakeRuntimeService) CreateBucket(ctx context.Context, req *iri.CreateBucketRequest) (*iri.CreateBucketResponse, error)

func (*FakeRuntimeService) DeleteBucket

func (r *FakeRuntimeService) DeleteBucket(ctx context.Context, req *iri.DeleteBucketRequest) (*iri.DeleteBucketResponse, error)

func (*FakeRuntimeService) ListBucketClasses

func (r *FakeRuntimeService) ListBucketClasses(ctx context.Context, req *iri.ListBucketClassesRequest) (*iri.ListBucketClassesResponse, error)

func (*FakeRuntimeService) ListBuckets

func (r *FakeRuntimeService) ListBuckets(ctx context.Context, req *iri.ListBucketsRequest) (*iri.ListBucketsResponse, error)

func (*FakeRuntimeService) ListEvents

func (r *FakeRuntimeService) ListEvents(ctx context.Context, req *iri.ListEventsRequest) (*iri.ListEventsResponse, error)

func (*FakeRuntimeService) SetBucketClasses

func (r *FakeRuntimeService) SetBucketClasses(bucketClasses []*FakeBucketClass)

func (*FakeRuntimeService) SetBuckets

func (r *FakeRuntimeService) SetBuckets(buckets []*FakeBucket)

func (*FakeRuntimeService) SetEvents

func (r *FakeRuntimeService) SetEvents(events []*FakeEvent)