build

Documentation

Index

• Constants
• func NewAgentInterflow(opts ...AgentInterflowOption) (interflow.AgentInterflow, error)
• func NewServerInterflow(opts ...ServerInterflowOption) (interflow.ServerInterflow, error)
• type AgentInterflowOption
  • func WithAgentGrpcNetwork(network hook.GrpcConfig) AgentInterflowOption
  • func WithAgentHttpNetwork(network hook.HttpConfig) AgentInterflowOption
  • func WithAgentKafka(kafkaMQServer *servers.KafkaMQServer) AgentInterflowOption
  • func WithAgentLogger(logger log.Logger) AgentInterflowOption
• type ServerInterflowOption
  • func WithServerKafka(kafkaMQServer *servers.KafkaMQServer) ServerInterflowOption
  • func WithServerLogger(logger log.Logger) ServerInterflowOption
  • func WithServerNetwork(network interflow.Network) ServerInterflowOption

Constants

const (
	Http interflowType = iota
	Grpc
	Kafka
)

Functions

func NewAgentInterflow

func NewAgentInterflow(opts ...AgentInterflowOption) (interflow.AgentInterflow, error)

func NewServerInterflow

func NewServerInterflow(opts ...ServerInterflowOption) (interflow.ServerInterflow, error)

Types

type AgentInterflowOption

type AgentInterflowOption func(*agentInterflow)

func WithAgentGrpcNetwork

func WithAgentGrpcNetwork(network hook.GrpcConfig) AgentInterflowOption

WithAgentGrpcNetwork 设置grpc hook通信网络

func WithAgentHttpNetwork

func WithAgentHttpNetwork(network hook.HttpConfig) AgentInterflowOption

WithAgentHttpNetwork 设置http hook通信网络

func WithAgentKafka

func WithAgentKafka(kafkaMQServer *servers.KafkaMQServer) AgentInterflowOption

WithAgentKafka 设置kafka

func WithAgentLogger

func WithAgentLogger(logger log.Logger) AgentInterflowOption

WithAgentLogger 设置日志

type ServerInterflowOption

type ServerInterflowOption func(s *serverInterflow)

func WithServerKafka

func WithServerKafka(kafkaMQServer *servers.KafkaMQServer) ServerInterflowOption

WithServerKafka 设置kafka

func WithServerLogger

func WithServerLogger(logger log.Logger) ServerInterflowOption

WithServerLogger 设置日志

func WithServerNetwork

func WithServerNetwork(network interflow.Network) ServerInterflowOption

WithServerNetwork 设置hook通信网络