pubsublog

Documentation

Index

• Constants
• type ClusterAuditActivityLogEntry
• type ClusterAuditActivityLogEntryData
• type LogLine
• type Resource
  • func (r Resource) Empty() bool
• type Subscriber
  • func NewSubscriber(pubsubSubscription *pubsub.Subscription, querier eventsql.Querier, ...) (*Subscriber, error)
  • func (s *Subscriber) Start(ctx context.Context) error

Constants

const (
	ActivityLogEntryResourceTypeClusterAudit activitylog.ActivityLogEntryResourceType = "CLUSTER_AUDIT"
)

Types

type ClusterAuditActivityLogEntry

type ClusterAuditActivityLogEntry struct {
	activitylog.GenericActivityLogEntry
	Data *ClusterAuditActivityLogEntryData
}

type ClusterAuditActivityLogEntryData

type ClusterAuditActivityLogEntryData struct {
	Action       string `json:"action,omitempty"`
	ResourceKind string `json:"resourceKind,omitempty"`
}

type LogLine

type LogLine struct {
	ProtoPayload struct {
		AuthenticationInfo struct {
			PrincipalEmail string `json:"principalEmail"`
		} `json:"authenticationInfo"`
		MethodName   string `json:"methodName"`
		ResourceName string `json:"resourceName"`
	} `json:"protoPayload"`

	Operation struct {
		ID uuid.UUID `json:"id"`
	} `json:"operation"`

	Resource struct {
		Labels struct {
			ClusterName string `json:"cluster_name"`
		} `json:"labels"`
	} `json:"resource"`
	Timestamp time.Time `json:"timestamp"`
}

type Resource

type Resource struct {
	GVR       *schema.GroupVersionResource
	Namespace string
	Name      string
	Extra     string
}

func (Resource) Empty

func (r Resource) Empty() bool

type Subscriber

type Subscriber struct {
	// contains filtered or unexported fields
}

func NewSubscriber

func NewSubscriber(pubsubSubscription *pubsub.Subscription, querier eventsql.Querier, mappers map[string]watcher.KindResolver, log logrus.FieldLogger) (*Subscriber, error)

func (*Subscriber) Start

func (s *Subscriber) Start(ctx context.Context) error