source

Documentation

Index

• type CassandraSource
  • func (source *CassandraSource) GetExceptionEvent(ctx context.Context, req *pb.GetExceptionEventRequest) (*pb.ExceptionEvent, error)
  • func (source *CassandraSource) GetExceptionEventIds(ctx context.Context, req *pb.GetExceptionEventIdsRequest) ([]string, error)
  • func (source *CassandraSource) GetExceptions(ctx context.Context, req *pb.GetExceptionsRequest) ([]*pb.Exception, error)
• type ElasticsearchSource
  • func (source *ElasticsearchSource) GetExceptionEvent(ctx context.Context, req *pb.GetExceptionEventRequest) (*pb.ExceptionEvent, error)
  • func (source *ElasticsearchSource) GetExceptionEventIds(ctx context.Context, req *pb.GetExceptionEventIdsRequest) ([]string, error)
  • func (source *ElasticsearchSource) GetExceptions(ctx context.Context, req *pb.GetExceptionsRequest) ([]*pb.Exception, error)
• type ExceptionSource

Types

type CassandraSource

type CassandraSource struct {
	CassandraSession *cassandra.Session
}

func (*CassandraSource) GetExceptionEvent

func (source *CassandraSource) GetExceptionEvent(ctx context.Context, req *pb.GetExceptionEventRequest) (*pb.ExceptionEvent, error)

func (*CassandraSource) GetExceptionEventIds

func (source *CassandraSource) GetExceptionEventIds(ctx context.Context, req *pb.GetExceptionEventIdsRequest) ([]string, error)

func (*CassandraSource) GetExceptions

func (source *CassandraSource) GetExceptions(ctx context.Context, req *pb.GetExceptionsRequest) ([]*pb.Exception, error)

type ElasticsearchSource

type ElasticsearchSource struct {
	Metric metricpb.MetricServiceServer
	Event  eventpb.EventQueryServiceServer
	Entity entitypb.EntityServiceServer
}

func (*ElasticsearchSource) GetExceptionEvent

func (source *ElasticsearchSource) GetExceptionEvent(ctx context.Context, req *pb.GetExceptionEventRequest) (*pb.ExceptionEvent, error)

func (*ElasticsearchSource) GetExceptionEventIds

func (source *ElasticsearchSource) GetExceptionEventIds(ctx context.Context, req *pb.GetExceptionEventIdsRequest) ([]string, error)

func (*ElasticsearchSource) GetExceptions

func (source *ElasticsearchSource) GetExceptions(ctx context.Context, req *pb.GetExceptionsRequest) ([]*pb.Exception, error)

type ExceptionSource

type ExceptionSource interface {
	GetExceptions(ctx context.Context, req *pb.GetExceptionsRequest) ([]*pb.Exception, error)
	GetExceptionEvent(ctx context.Context, req *pb.GetExceptionEventRequest) (*pb.ExceptionEvent, error)
	GetExceptionEventIds(ctx context.Context, req *pb.GetExceptionEventIdsRequest) ([]string, error)
}