mock

package
v1.0.0-beta.34 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 29, 2025 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ContextKey added in v1.0.0 

type ContextKey string
const SpanNameKey ContextKey = "mock-span-name"

type MockContext 

type MockContext struct {
	*fasthttp.RequestCtx
	CtxFn               func() context.Context
	SetCtxFn            func(ctx context.Context)
	ConfigFn            func() *raiden.Config
	SendJsonFn          func(data any) error
	SendErrorFn         func(err string) error
	SendErrorWithCodeFn func(statusCode int, err error) error
	RequestContextFn    func() *fasthttp.RequestCtx
	SendRpcFn           func(rpc raiden.Rpc) error
	ExecuteRpcFn        func(rpc raiden.Rpc) (any, error)
	SpanFn              func() trace.Span
	SetSpanFn           func(span trace.Span)
	TracerFn            func() trace.Tracer
	NewJobCtxFn         func() (raiden.JobContext, error)
	WriteFn             func(data []byte)
	WriteErrorFn        func(err error)
	SetFn               func(key string, value any)
	GetFn               func(key string) any
	Data                map[string]any
	PublishFn           func(ctx context.Context, provider raiden.PubSubProviderType, topic string, message []byte) error
}

func (*MockContext) Config 

func (c *MockContext) Config() *raiden.Config

func (*MockContext) Ctx 

func (c *MockContext) Ctx() context.Context

func (*MockContext) ExecuteRpc 

func (c *MockContext) ExecuteRpc(rpc raiden.Rpc) (any, error)

func (*MockContext) Get 

func (c *MockContext) Get(key string) any

func (*MockContext) NewJobCtx 

func (c *MockContext) NewJobCtx() (raiden.JobContext, error)

func (*MockContext) Publish added in v1.0.0 

func (c *MockContext) Publish(ctx context.Context, provider raiden.PubSubProviderType, topic string, message []byte) error

func (*MockContext) RequestContext 

func (c *MockContext) RequestContext() *fasthttp.RequestCtx

func (*MockContext) SendError 

func (c *MockContext) SendError(message string) error

func (*MockContext) SendErrorWithCode 

func (c *MockContext) SendErrorWithCode(statusCode int, err error) error

func (*MockContext) SendJson 

func (c *MockContext) SendJson(data any) error

func (*MockContext) SendRpc 

func (c *MockContext) SendRpc(rpc raiden.Rpc) error

func (*MockContext) Set 

func (c *MockContext) Set(key string, value any)

func (*MockContext) SetCtx 

func (c *MockContext) SetCtx(ctx context.Context)

func (*MockContext) SetSpan 

func (c *MockContext) SetSpan(span trace.Span)

func (*MockContext) Span 

func (c *MockContext) Span() trace.Span

func (*MockContext) Tracer 

func (c *MockContext) Tracer() trace.Tracer

func (*MockContext) Write 

func (c *MockContext) Write(data []byte)

func (*MockContext) WriteError 

func (c *MockContext) WriteError(err error)

type MockProvider added in v1.0.0 

type MockProvider struct {
	CreateSubscriptionFn func(handler raiden.SubscriberHandler) error
	PublishFn            func(ctx context.Context, topic string, message []byte) error
	StartListenFn        func(handler []raiden.SubscriberHandler) error
	StopListenFn         func() error
}

func (*MockProvider) CreateSubscription added in v1.0.0 

func (m *MockProvider) CreateSubscription(handler raiden.SubscriberHandler) error

Publish implements raiden.PubSubProvider.

func (*MockProvider) Publish added in v1.0.0 

func (m *MockProvider) Publish(ctx context.Context, topic string, message []byte) error

Publish implements raiden.PubSubProvider.

func (*MockProvider) StartListen added in v1.0.0 

func (m *MockProvider) StartListen(handler []raiden.SubscriberHandler) error

StartListen implements raiden.PubSubProvider.

func (*MockProvider) StopListen added in v1.0.0 

func (m *MockProvider) StopListen() error

StopListen implements raiden.PubSubProvider.

type MockPubSubClient added in v1.0.0 

type MockPubSubClient struct {
	Subscriptions        map[string]*MockSubscription
	Topics               map[string]*MockTopic
	CloseFn              func() error
	CreateSubscriptionFn func(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (google.Subscription, error)
}

func (*MockPubSubClient) Close added in v1.0.0 

func (m *MockPubSubClient) Close() error

func (*MockPubSubClient) CreateSubscription added in v1.0.0 

func (m *MockPubSubClient) CreateSubscription(ctx context.Context, id string, cfg pubsub.SubscriptionConfig) (google.Subscription, error)

func (*MockPubSubClient) Subscription added in v1.0.0 

func (m *MockPubSubClient) Subscription(id string) google.Subscription

func (*MockPubSubClient) Topic added in v1.0.0 

func (m *MockPubSubClient) Topic(id string) google.Topic

type MockPublishResult added in v1.0.0 

type MockPublishResult struct {
	Result string
	Err    error
}

func (*MockPublishResult) Get added in v1.0.0 

func (m *MockPublishResult) Get(ctx context.Context) (string, error)

type MockSpan added in v1.0.0 

type MockSpan struct {
	embedded.Span

	Name           string
	Attributes     []attribute.KeyValue
	StatusCode     codes.Code
	StatusMessage  string
	RecordingState bool
	SpanCtx        trace.SpanContext
	Events         []string
	Links          []trace.Link
}

func (*MockSpan) AddEvent added in v1.0.0 

func (m *MockSpan) AddEvent(name string, options ...trace.EventOption)
func (m *MockSpan) AddLink(link trace.Link)

func (*MockSpan) End added in v1.0.0 

func (m *MockSpan) End(options ...trace.SpanEndOption)

func (*MockSpan) IsRecording added in v1.0.0 

func (m *MockSpan) IsRecording() bool

func (*MockSpan) RecordError added in v1.0.0 

func (m *MockSpan) RecordError(err error, options ...trace.EventOption)

func (*MockSpan) SetAttributes added in v1.0.0 

func (m *MockSpan) SetAttributes(kv ...attribute.KeyValue)

func (*MockSpan) SetName added in v1.0.0 

func (m *MockSpan) SetName(name string)

func (*MockSpan) SetStatus added in v1.0.0 

func (m *MockSpan) SetStatus(code codes.Code, description string)

func (*MockSpan) SpanContext added in v1.0.0 

func (m *MockSpan) SpanContext() trace.SpanContext

func (*MockSpan) TracerProvider added in v1.0.0 

func (m *MockSpan) TracerProvider() trace.TracerProvider

type MockSubscriberHandler added in v1.0.0 

type MockSubscriberHandler struct {
	TopicValue            string
	SubscriptionValue     string
	NameValue             string
	PushEndpointValue     string
	AutoAckValue          bool
	ProviderValue         raiden.PubSubProviderType
	SubscriptionTypeValue raiden.SubscriptionType
	ConsumeFunc           func(ctx raiden.SubscriberContext, msg any) error
}

func (*MockSubscriberHandler) AutoAck added in v1.0.0 

func (m *MockSubscriberHandler) AutoAck() bool

func (*MockSubscriberHandler) Consume added in v1.0.0 

func (m *MockSubscriberHandler) Consume(ctx raiden.SubscriberContext, msg any) error

func (*MockSubscriberHandler) Name added in v1.0.0 

func (m *MockSubscriberHandler) Name() string

func (*MockSubscriberHandler) Provider added in v1.0.0 

func (m *MockSubscriberHandler) Provider() raiden.PubSubProviderType

func (*MockSubscriberHandler) PushEndpoint added in v1.0.0 

func (m *MockSubscriberHandler) PushEndpoint() string

func (*MockSubscriberHandler) Subscription added in v1.0.0 

func (m *MockSubscriberHandler) Subscription() string

func (*MockSubscriberHandler) SubscriptionType added in v1.0.0 

func (m *MockSubscriberHandler) SubscriptionType() raiden.SubscriptionType

func (*MockSubscriberHandler) Topic added in v1.0.0 

func (m *MockSubscriberHandler) Topic() string

type MockSubscription added in v1.0.0 

type MockSubscription struct {
	Id        string
	ReceiveFn func(ctx context.Context, f func(ctx context.Context, msg *pubsub.Message)) error
}

func (*MockSubscription) ID added in v1.0.0 

func (m *MockSubscription) ID() string

func (*MockSubscription) Receive added in v1.0.0 

func (m *MockSubscription) Receive(ctx context.Context, f func(ctx context.Context, msg *pubsub.Message)) error

type MockSupabase 

type MockSupabase struct {
	Cfg *raiden.Config
}

func (*MockSupabase) Activate 

func (m *MockSupabase) Activate()

func (*MockSupabase) Deactivate 

func (m *MockSupabase) Deactivate()

func (*MockSupabase) MockAdminUpdateUserDataWithExpectedResponse 

func (m *MockSupabase) MockAdminUpdateUserDataWithExpectedResponse(httpCode int, user objects.User) error

func (*MockSupabase) MockCreateBucketsWithExpectedResponse 

func (m *MockSupabase) MockCreateBucketsWithExpectedResponse(httpCode int, data interface{}) error

func (*MockSupabase) MockCreateFunctionWithExpectedResponse 

func (m *MockSupabase) MockCreateFunctionWithExpectedResponse(httpCode int, function objects.Function) error

func (*MockSupabase) MockCreatePolicyWithExpectedResponse 

func (m *MockSupabase) MockCreatePolicyWithExpectedResponse(httpCode int, policy objects.Policy) error

func (*MockSupabase) MockCreateRoleWithExpectedResponse 

func (m *MockSupabase) MockCreateRoleWithExpectedResponse(httpCode int, role objects.Role) error

func (*MockSupabase) MockCreateTableWithExpectedResponse 

func (m *MockSupabase) MockCreateTableWithExpectedResponse(httpCode int, table objects.Table) error

func (*MockSupabase) MockDeleteBucketsWithExpectedResponse 

func (m *MockSupabase) MockDeleteBucketsWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockDeleteFunctionWithExpectedResponse 

func (m *MockSupabase) MockDeleteFunctionWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockDeletePolicyWithExpectedResponse 

func (m *MockSupabase) MockDeletePolicyWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockDeleteRoleWithExpectedResponse 

func (m *MockSupabase) MockDeleteRoleWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockDeleteTableWithExpectedResponse 

func (m *MockSupabase) MockDeleteTableWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockExecuteRpcWithExpectedResponse 

func (m *MockSupabase) MockExecuteRpcWithExpectedResponse(httpCode int, rpcName string, data interface{}) error

func (*MockSupabase) MockFindProjectWithExpectedResponse 

func (m *MockSupabase) MockFindProjectWithExpectedResponse(httpCode int, project objects.Project) error

func (*MockSupabase) MockGetBucketByNameWithExpectedResponse 

func (m *MockSupabase) MockGetBucketByNameWithExpectedResponse(httpCode int, bucket objects.Bucket) error

func (*MockSupabase) MockGetBucketsWithExpectedResponse 

func (m *MockSupabase) MockGetBucketsWithExpectedResponse(httpCode int, data interface{}) error

func (*MockSupabase) MockGetFunctionByNameWithExpectedResponse 

func (m *MockSupabase) MockGetFunctionByNameWithExpectedResponse(httpCode int, function objects.Function) error

func (*MockSupabase) MockGetFunctionsWithExpectedResponse 

func (m *MockSupabase) MockGetFunctionsWithExpectedResponse(httpCode int, functions []objects.Function) error

func (*MockSupabase) MockGetPoliciesWithExpectedResponse 

func (m *MockSupabase) MockGetPoliciesWithExpectedResponse(httpCode int, policies []objects.Policy) error

func (*MockSupabase) MockGetPolicyByNameWithExpectedResponse 

func (m *MockSupabase) MockGetPolicyByNameWithExpectedResponse(httpCode int, policy objects.Policy) error

func (*MockSupabase) MockGetRoleByNameWithExpectedResponse 

func (m *MockSupabase) MockGetRoleByNameWithExpectedResponse(httpCode int, role objects.Role) error

func (*MockSupabase) MockGetRolesWithExpectedResponse 

func (m *MockSupabase) MockGetRolesWithExpectedResponse(httpCode int, roles []objects.Role) error

func (*MockSupabase) MockGetTableByNameWithExpectedResponse 

func (m *MockSupabase) MockGetTableByNameWithExpectedResponse(httpCode int, table objects.Table) error

func (*MockSupabase) MockGetTablesWithExpectedResponse 

func (m *MockSupabase) MockGetTablesWithExpectedResponse(httpCode int, tables []objects.Table) error

func (*MockSupabase) MockUpdateFunctionWithExpectedResponse 

func (m *MockSupabase) MockUpdateFunctionWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockUpdatePolicyWithExpectedResponse 

func (m *MockSupabase) MockUpdatePolicyWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockUpdateRoleWithExpectedResponse 

func (m *MockSupabase) MockUpdateRoleWithExpectedResponse(httpCode int) error

func (*MockSupabase) MockUpdateTableWithExpectedResponse 

func (m *MockSupabase) MockUpdateTableWithExpectedResponse(httpCode int) error

type MockTopic added in v1.0.0 

type MockTopic struct {
	PublishFn func(ctx context.Context, msg *pubsub.Message) google.PublishResult
}

func (*MockTopic) GetInstance added in v1.0.0 

func (m *MockTopic) GetInstance() *pubsub.Topic

func (*MockTopic) Publish added in v1.0.0 

func (m *MockTopic) Publish(ctx context.Context, msg *pubsub.Message) google.PublishResult

type MockTracer added in v1.0.0 

type MockTracer struct {
	embedded.Tracer
}

func (*MockTracer) Start added in v1.0.0 

func (m *MockTracer) Start(ctx context.Context, spanName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.