integrations

Documentation

Index

• func EchoV4(app *keploy.App, e *echo.Echo)
• func NewMiddlewareContextValue(fn echo.HandlerFunc) echo.HandlerFunc
• func StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
• func WebGoV4(app *keploy.App, w *webgo.Router)
• func WebGoV6(app *keploy.App, w *webgo.Router)
• func WithClientStreamInterceptor() grpc.DialOption
• func WithClientUnaryInterceptor(app *keploy.App) grpc.DialOption
• type DynamoDB
  • func NewDynamoDB(cl *dynamodb.DynamoDB) *DynamoDB
  • func (c *DynamoDB) GetItemWithContext(ctx aws.Context, input *dynamodb.GetItemInput, opts ...request.Option) (*dynamodb.GetItemOutput, error)
  • func (c *DynamoDB) PutItemWithContext(ctx aws.Context, input *dynamodb.PutItemInput, opts ...request.Option) (*dynamodb.PutItemOutput, error)
  • func (c *DynamoDB) QueryWithContext(ctx aws.Context, input *dynamodb.QueryInput, opts ...request.Option) (*dynamodb.QueryOutput, error)
• type MongoCursor
  • func (cr *MongoCursor) Decode(v interface{}) error
  • func (cr *MongoCursor) Next(ctx context.Context) bool
• type MongoDB
  • func NewMongoDB(cl *mongo.Collection) *MongoDB
  • func (c *MongoDB) DeleteMany(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
  • func (c *MongoDB) DeleteOne(ctx context.Context, filter interface{}, opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)
  • func (c *MongoDB) Find(ctx context.Context, filter interface{}, opts ...*options.FindOptions) (*MongoCursor, error)
  • func (c *MongoDB) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *MongoSingleResult
  • func (c *MongoDB) InsertMany(ctx context.Context, documents []interface{}, ...) (*mongo.InsertManyResult, error)
  • func (c *MongoDB) InsertOne(ctx context.Context, document interface{}, opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)
  • func (c *MongoDB) UpdateMany(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)
  • func (c *MongoDB) UpdateOne(ctx context.Context, filter interface{}, update interface{}, ...) (*mongo.UpdateResult, error)
• type MongoSingleResult
  • func (msr *MongoSingleResult) Decode(v interface{}) error
  • func (msr *MongoSingleResult) Err() error

Functions

func EchoV4

func EchoV4(app *keploy.App, e *echo.Echo)

func NewMiddlewareContextValue

func NewMiddlewareContextValue(fn echo.HandlerFunc) echo.HandlerFunc

func StreamClientInterceptor

func StreamClientInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

not added KError for encoding and decoding

func WebGoV4

func WebGoV4(app *keploy.App, w *webgo.Router)

func WebGoV6

func WebGoV6(app *keploy.App, w *webgo.Router)

func WithClientStreamInterceptor

func WithClientStreamInterceptor() grpc.DialOption

func WithClientUnaryInterceptor

func WithClientUnaryInterceptor(app *keploy.App) grpc.DialOption

Types

type DynamoDB

type DynamoDB struct {
	dynamodb.DynamoDB
	// contains filtered or unexported fields
}

func NewDynamoDB

func NewDynamoDB(cl *dynamodb.DynamoDB) *DynamoDB

func (*DynamoDB) GetItemWithContext

func (c *DynamoDB) GetItemWithContext(ctx aws.Context, input *dynamodb.GetItemInput, opts ...request.Option) (*dynamodb.GetItemOutput, error)

func (*DynamoDB) PutItemWithContext

func (c *DynamoDB) PutItemWithContext(ctx aws.Context, input *dynamodb.PutItemInput, opts ...request.Option) (*dynamodb.PutItemOutput, error)

func (*DynamoDB) QueryWithContext

func (c *DynamoDB) QueryWithContext(ctx aws.Context, input *dynamodb.QueryInput, opts ...request.Option) (*dynamodb.QueryOutput, error)

type MongoCursor

type MongoCursor struct {
	mongo.Cursor
	// contains filtered or unexported fields
}

func (*MongoCursor) Decode

func (cr *MongoCursor) Decode(v interface{}) error

func (*MongoCursor) Next

func (cr *MongoCursor) Next(ctx context.Context) bool

type MongoDB

type MongoDB struct {
	mongo.Collection
	// contains filtered or unexported fields
}

func NewMongoDB

func NewMongoDB(cl *mongo.Collection) *MongoDB

func (*MongoDB) DeleteMany

func (c *MongoDB) DeleteMany(ctx context.Context, filter interface{},
	opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

func (*MongoDB) DeleteOne

func (c *MongoDB) DeleteOne(ctx context.Context, filter interface{},
	opts ...*options.DeleteOptions) (*mongo.DeleteResult, error)

func (*MongoDB) Find

func (c *MongoDB) Find(ctx context.Context, filter interface{},
	opts ...*options.FindOptions) (*MongoCursor, error)

have to work on this. It might fail

func (*MongoDB) FindOne

func (c *MongoDB) FindOne(ctx context.Context, filter interface{}, opts ...*options.FindOneOptions) *MongoSingleResult

func (*MongoDB) InsertMany

func (c *MongoDB) InsertMany(ctx context.Context, documents []interface{},
	opts ...*options.InsertManyOptions) (*mongo.InsertManyResult, error)

func (*MongoDB) InsertOne

func (c *MongoDB) InsertOne(ctx context.Context, document interface{},
	opts ...*options.InsertOneOptions) (*mongo.InsertOneResult, error)

func (*MongoDB) UpdateMany

func (c *MongoDB) UpdateMany(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

func (*MongoDB) UpdateOne

func (c *MongoDB) UpdateOne(ctx context.Context, filter interface{}, update interface{},
	opts ...*options.UpdateOptions) (*mongo.UpdateResult, error)

type MongoSingleResult

type MongoSingleResult struct {
	mongo.SingleResult
	// contains filtered or unexported fields
}

func (*MongoSingleResult) Decode

func (msr *MongoSingleResult) Decode(v interface{}) error

func (*MongoSingleResult) Err

func (msr *MongoSingleResult) Err() error