logs

Documentation

Index

• func LogHash(md MsgData, userId repos.ID, sid string) string
• func LogSubsId(md MsgData, logStreamName string) string
• func ParseSince(since *string) (*time.Time, error)
• type Event
• type LogsSubs
• type LogsSubsMap
• type Message
• type MsgData
• type Response

Functions

func LogHash

func LogHash(md MsgData, userId repos.ID, sid string) string

func LogSubsId

func LogSubsId(md MsgData, logStreamName string) string

func ParseSince

func ParseSince(since *string) (*time.Time, error)

Types

type Event

type Event string

const (
	EventSubscribe   Event = "subscribe"
	EventUnsubscribe Event = "unsubscribe"
)

type LogsSubs

type LogsSubs struct {
	Jc       *msg_nats.JetstreamConsumer
	Id       string
	Resource MsgData
}

type LogsSubsMap

type LogsSubsMap map[string]LogsSubs

type Message

type Message struct {
	Event Event   `json:"event"`
	Spec  MsgData `json:"spec"`
	Id    string  `json:"id"`
}

type MsgData

type MsgData struct {
	Account       string  `json:"account"`
	Cluster       string  `json:"cluster"`
	TrackingId    string  `json:"trackingId"`
	Since         *string `json:"since,omitempty"`
	RecordVersion *int    `json:"recordVersion"`
}

type Response

type Response struct {
	Message       string    `json:"message"`
	Timestamp     time.Time `json:"timestamp"`
	PodName       string    `json:"podName"`
	ContainerName string    `json:"containerName"`
}