bus

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 19, 2025 License: Apache-2.0 Imports: 5 Imported by: 7

Documentation

Index

Constants

View Source 
const MessageBus_BusType_not_set_case case_MessageBus_BusType = 0
View Source 
const MessageBus_InMemory_case case_MessageBus_BusType = 1
View Source 
const MessageBus_Nats_case case_MessageBus_BusType = 3
View Source 
const MessageBus_Redis_case case_MessageBus_BusType = 2

Variables

View Source 
var File_proto_bus_bus_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type InMemoryBus 

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

func (*InMemoryBus) ProtoMessage 

func (*InMemoryBus) ProtoMessage()

func (*InMemoryBus) ProtoReflect 

func (x *InMemoryBus) ProtoReflect() protoreflect.Message

func (*InMemoryBus) Reset 

func (x *InMemoryBus) Reset()

func (*InMemoryBus) String 

func (x *InMemoryBus) String() string

type InMemoryBus_builder 

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

func (InMemoryBus_builder) Build 

func (b0 InMemoryBus_builder) Build() *InMemoryBus

type MessageBus 

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

func (*MessageBus) ClearBusType 

func (x *MessageBus) ClearBusType()

func (*MessageBus) ClearInMemory 

func (x *MessageBus) ClearInMemory()

func (*MessageBus) ClearNats 

func (x *MessageBus) ClearNats()

func (*MessageBus) ClearRedis 

func (x *MessageBus) ClearRedis()

func (*MessageBus) GetInMemory 

func (x *MessageBus) GetInMemory() *InMemoryBus

func (*MessageBus) GetNats 

func (x *MessageBus) GetNats() *NatsBus

func (*MessageBus) GetRedis 

func (x *MessageBus) GetRedis() *RedisBus

func (*MessageBus) HasBusType 

func (x *MessageBus) HasBusType() bool

func (*MessageBus) HasInMemory 

func (x *MessageBus) HasInMemory() bool

func (*MessageBus) HasNats 

func (x *MessageBus) HasNats() bool

func (*MessageBus) HasRedis 

func (x *MessageBus) HasRedis() bool

func (*MessageBus) ProtoMessage 

func (*MessageBus) ProtoMessage()

func (*MessageBus) ProtoReflect 

func (x *MessageBus) ProtoReflect() protoreflect.Message

func (*MessageBus) Reset 

func (x *MessageBus) Reset()

func (*MessageBus) SetInMemory 

func (x *MessageBus) SetInMemory(v *InMemoryBus)

func (*MessageBus) SetNats 

func (x *MessageBus) SetNats(v *NatsBus)

func (*MessageBus) SetRedis 

func (x *MessageBus) SetRedis(v *RedisBus)

func (*MessageBus) String 

func (x *MessageBus) String() string

func (*MessageBus) WhichBusType 

func (x *MessageBus) WhichBusType() case_MessageBus_BusType

type MessageBus_builder 

type MessageBus_builder struct {

	// Fields of oneof xxx_hidden_BusType:
	InMemory *InMemoryBus
	Redis    *RedisBus
	Nats     *NatsBus
	// contains filtered or unexported fields
}

func (MessageBus_builder) Build 

func (b0 MessageBus_builder) Build() *MessageBus

type NatsBus 

type NatsBus struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*NatsBus) ClearServerUrl 

func (x *NatsBus) ClearServerUrl()

func (*NatsBus) GetServerUrl 

func (x *NatsBus) GetServerUrl() string

func (*NatsBus) HasServerUrl 

func (x *NatsBus) HasServerUrl() bool

func (*NatsBus) ProtoMessage 

func (*NatsBus) ProtoMessage()

func (*NatsBus) ProtoReflect 

func (x *NatsBus) ProtoReflect() protoreflect.Message

func (*NatsBus) Reset 

func (x *NatsBus) Reset()

func (*NatsBus) SetServerUrl 

func (x *NatsBus) SetServerUrl(v string)

func (*NatsBus) String 

func (x *NatsBus) String() string

type NatsBus_builder 

type NatsBus_builder struct {
	ServerUrl *string
	// contains filtered or unexported fields
}

func (NatsBus_builder) Build 

func (b0 NatsBus_builder) Build() *NatsBus

type RedisBus 

type RedisBus struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

func (*RedisBus) ClearAddress 

func (x *RedisBus) ClearAddress()

func (*RedisBus) ClearDb 

func (x *RedisBus) ClearDb()

func (*RedisBus) ClearPassword 

func (x *RedisBus) ClearPassword()

func (*RedisBus) GetAddress 

func (x *RedisBus) GetAddress() string

func (*RedisBus) GetDb 

func (x *RedisBus) GetDb() int32

func (*RedisBus) GetPassword 

func (x *RedisBus) GetPassword() string

func (*RedisBus) HasAddress 

func (x *RedisBus) HasAddress() bool

func (*RedisBus) HasDb 

func (x *RedisBus) HasDb() bool

func (*RedisBus) HasPassword 

func (x *RedisBus) HasPassword() bool

func (*RedisBus) ProtoMessage 

func (*RedisBus) ProtoMessage()

func (*RedisBus) ProtoReflect 

func (x *RedisBus) ProtoReflect() protoreflect.Message

func (*RedisBus) Reset 

func (x *RedisBus) Reset()

func (*RedisBus) SetAddress 

func (x *RedisBus) SetAddress(v string)

func (*RedisBus) SetDb 

func (x *RedisBus) SetDb(v int32)

func (*RedisBus) SetPassword 

func (x *RedisBus) SetPassword(v string)

func (*RedisBus) String 

func (x *RedisBus) String() string

type RedisBus_builder 

type RedisBus_builder struct {
	Address  *string
	Db       *int32
	Password *string
	// contains filtered or unexported fields
}

func (RedisBus_builder) Build 

func (b0 RedisBus_builder) Build() *RedisBus

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.