Documentation
¶
Index ¶
- Constants
- func ParseGrpcMethod(methodName string) (string, string, error)
- type GrpcTrigger
- type HTTPTrigger
- type JetstreamTrigger
- type NATSConnector
- type NATSJWTConnector
- type NATSMTLSConnector
- type NATSNKeyConnector
- type NATSNoAuthConnector
- type NATSTokenConnector
- type NATSTrigger
- type NATSUserPassConnector
- type PlaywrightTrigger
- type ProtoFileServiceDescriptor
- type ServerReflectionServiceDescriptor
- type ServiceDescriptor
- type TraceId
- type TraceIdTrigger
- type Trigger
Constants ¶
View Source
const ( DEFAULT_HTTP_METHOD = "GET" DEFAULT_TIMEOUT = 10 * time.Second )
View Source
const ( PLAYWRIGHT_SERVER_ENDPOINT = "/traceparent" DEFAULT_PLAYWRIGHT_PATH = "playwright" DEFAULT_URL_PATTERN = "**" )
View Source
const (
NATS_SERVER_URL_FORMAT = "nats://%s"
)
Variables ¶
This section is empty.
Functions ¶
Types ¶
type GrpcTrigger ¶
type GrpcTrigger struct {
// contains filtered or unexported fields
}
func (*GrpcTrigger) Example ¶
func (t *GrpcTrigger) Example() string
func (*GrpcTrigger) Init ¶
func (g *GrpcTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*GrpcTrigger) Trigger ¶
func (g *GrpcTrigger) Trigger() (TraceId, error)
type HTTPTrigger ¶
type HTTPTrigger struct {
// contains filtered or unexported fields
}
func (*HTTPTrigger) Example ¶
func (t *HTTPTrigger) Example() string
func (*HTTPTrigger) Init ¶
func (t *HTTPTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*HTTPTrigger) Trigger ¶
func (t *HTTPTrigger) Trigger() (TraceId, error)
type JetstreamTrigger ¶
type JetstreamTrigger struct {
NATSTrigger
// contains filtered or unexported fields
}
func (*JetstreamTrigger) Example ¶
func (t *JetstreamTrigger) Example() string
func (*JetstreamTrigger) Init ¶
func (j *JetstreamTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*JetstreamTrigger) Trigger ¶
func (j *JetstreamTrigger) Trigger() (TraceId, error)
type NATSConnector ¶
type NATSConnector interface {
Connect(serverAddress string, caPemPath *string) (*nats.Conn, error)
}
func NewNATSConnector ¶
func NewNATSConnector(dto *parser.TriggerDTO, baseDir string) (NATSConnector, error)
type NATSJWTConnector ¶
type NATSJWTConnector struct {
// contains filtered or unexported fields
}
JWT authentication
func NewNATSJWTConnector ¶
func NewNATSJWTConnector(jwt string, seed string) *NATSJWTConnector
type NATSMTLSConnector ¶
type NATSMTLSConnector struct {
// contains filtered or unexported fields
}
mTLS authentication
func NewNATSMTLSConnector ¶
func NewNATSMTLSConnector(clientCertPath, clientKeyPath, baseDir string) *NATSMTLSConnector
type NATSNKeyConnector ¶
type NATSNKeyConnector struct {
// contains filtered or unexported fields
}
NKey authentication
func NewNATSNKeyConnector ¶
func NewNATSNKeyConnector(seed string) *NATSNKeyConnector
type NATSNoAuthConnector ¶
type NATSNoAuthConnector struct{}
No authentication
func NewNATSNoAuthConnector ¶
func NewNATSNoAuthConnector() *NATSNoAuthConnector
type NATSTokenConnector ¶
type NATSTokenConnector struct {
// contains filtered or unexported fields
}
Token authentication
func NewNATSTokenConnector ¶
func NewNATSTokenConnector(token string) *NATSTokenConnector
type NATSTrigger ¶
type NATSTrigger struct {
// contains filtered or unexported fields
}
func (*NATSTrigger) Example ¶
func (t *NATSTrigger) Example() string
func (*NATSTrigger) Init ¶
func (t *NATSTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*NATSTrigger) Trigger ¶
func (t *NATSTrigger) Trigger() (TraceId, error)
type NATSUserPassConnector ¶
type NATSUserPassConnector struct {
// contains filtered or unexported fields
}
User and password authentication
func NewNATSUserPassConnector ¶
func NewNATSUserPassConnector(username, password string) *NATSUserPassConnector
type PlaywrightTrigger ¶
type PlaywrightTrigger struct {
// contains filtered or unexported fields
}
func (*PlaywrightTrigger) Example ¶
func (t *PlaywrightTrigger) Example() string
func (*PlaywrightTrigger) Init ¶
func (t *PlaywrightTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*PlaywrightTrigger) Trigger ¶
func (t *PlaywrightTrigger) Trigger() (TraceId, error)
type ProtoFileServiceDescriptor ¶
type ProtoFileServiceDescriptor struct {
// contains filtered or unexported fields
}
func NewProtoFileServiceDescriptor ¶
func NewProtoFileServiceDescriptor(dto *parser.TriggerDTO, baseDir string, ctx context.Context) (*ProtoFileServiceDescriptor, error)
func (*ProtoFileServiceDescriptor) Get ¶
func (p *ProtoFileServiceDescriptor) Get(serviceName string) (protoreflect.ServiceDescriptor, error)
type ServerReflectionServiceDescriptor ¶
type ServerReflectionServiceDescriptor struct {
// contains filtered or unexported fields
}
func NewServerReflectionServiceDescriptor ¶
func NewServerReflectionServiceDescriptor(dto *parser.TriggerDTO, serverAddress string, ctx context.Context) (*ServerReflectionServiceDescriptor, error)
func (*ServerReflectionServiceDescriptor) Get ¶
func (s *ServerReflectionServiceDescriptor) Get(serviceName string) (protoreflect.ServiceDescriptor, error)
type ServiceDescriptor ¶
type ServiceDescriptor interface {
Get(serviceName string) (protoreflect.ServiceDescriptor, error)
}
func NewServiceDescriptor ¶
func NewServiceDescriptor(dto *parser.TriggerDTO, baseDir, serverAddress string, ctx context.Context) (ServiceDescriptor, error)
type TraceIdTrigger ¶
type TraceIdTrigger struct {
// contains filtered or unexported fields
}
func (*TraceIdTrigger) Example ¶
func (t *TraceIdTrigger) Example() string
func (*TraceIdTrigger) Init ¶
func (t *TraceIdTrigger) Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
func (*TraceIdTrigger) Trigger ¶
func (t *TraceIdTrigger) Trigger() (TraceId, error)
type Trigger ¶
type Trigger interface {
Trigger() (TraceId, error)
Example() string
Init(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) error
}
func NewTrigger ¶
func NewTrigger(dto *parser.TriggerDTO, idGenerator idgenerator.IdGenerator, baseDir string, ctx context.Context) (Trigger, error)
func NewTriggerFromType ¶
Source Files
Click to show internal directories.
Click to hide internal directories.